欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

MySQLdb方式操作数据库

程序员文章站 2024-02-10 13:04:16
...
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:[email protected]/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()

更多MySQLdb的使用方法见http://www.runoob.com/python/python-mysql.html

相关标签: MySQLdb MySQL