首页 > 代码库 > 个人MySQL股票数据库的建立日记
个人MySQL股票数据库的建立日记
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
import tushare as ts
from sqlalchemy import create_engine
code = "002312"
#数据库链接参数
host = ‘192.168.0.165‘
port = 3306
user = ‘root‘
password = ‘qweqwe‘
database = ‘stock‘
charset = "utf8"
#建立数据库连接
conn = MySQLdb.connect(
host=host,
port=port,
user=user,
passwd=password,
db=database,
)
#获取游标
cur = conn.cursor()
#创建表的sql语句
create_table_sql = "create table if not exists code" + code + "(id int auto_increment,code int(6) zerofill,date date not null,open decimal(10,2) not null,high decimal(10,2) not null,close decimal(10,2) not null,low decimal(10,2) not null,volume decimal(10,2),turnover decimal(10,2),primary key (id))"
#执行sql语句
cur.execute(create_table_sql)
#关闭游标
cur.close()
#提交连接
conn.commit()
#断开连接
conn.close()
#获取股票历史k线数据
df = ts.get_hist_data(code)
#筛选数据,只获取open high close low volume turnover列,并到倒序排列
data = http://www.mamicode.com/df.iloc[::-1, [0, 1, 2, 3, 4, 13]]
#为dataframe添加code列,因为数据库中需要这一列建立索引
data["code"] = code
# 创建数据库引擎
engine = create_engine(‘mysql://‘ + user + ‘:‘ + password + ‘@‘ + host + ‘/‘ + database + ‘?charset=‘ + charset)
#将数据存入数据库,如果表存在增量存储
data.to_sql(‘code‘+code, engine, if_exists=‘append‘)
个人MySQL股票数据库的建立日记
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。