MySQL db方式操作数据库的实例详解

mysql db方式操作的实例详解

from sqlalchemy import create_engine
import tushare as ts

df=ts.get_k_data('600000',start='2017-05-31',end='2018-05-31')

engine = create_engine('mysql://root:123456@127.0.0.1/stock_data')

df.to_sql('tick_data',engine)

c:\programdata\anaconda2\lib\site-packages\sqlalchemy\engine\default.py:470: warning: incorrect string value: '\xd6\xd0\xb9\xfa\xb1\xea...' for column 'variable_value' at row 480
  cursor.execute(statement, parameters)

df1=ts.get_k_data('600000',start='2018-06-01',end='2018-06-05')

#使用pandas自带的方式存入数据库
df1.to_sql('tick_data',engine,if_exists='append')

import mysqldb

# 打开数据库连接
db=mysqldb.connect("localhost", "root", "123456", "stock_data", charset='utf8' )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# 使用execute方法执行sql语句
cursor.execute("select * from tick_data")

249l

# 使用 fetchone() 方法获取一条数据
data_one = cursor.fetchone()

print data_one

(96l, u'2017-05-31', 12.75, 12.84, 13.05, 12.66, 1130098.0, u'600000')

# 使用 fetchall() 方法获取一条数据
data_all = cursor.fetchall()

db.close()