股票历史数据下载 2017-03-15 08:47 采纳率: 0%
浏览 2505

获取到的数据生成新的mysql表或插入到已有表-Python

 # -*- conding:utf8 -*-
import tushare as ts
import pymysql
conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='root', db='test')
cursor = conn.cursor() #创建游标
today_data = ts.get_today_all() #把获取到的数据给today_data

代码如上,可以成功连接数据库,创建游标,获取到数据。问题是:today_data获取到的数据有多个字段(code、name、changepercent、trade、open high、low、settlement),那如何在获取到数据的时候,生成一张新表?新表的字段和获取到的字段一致。

  • 写回答

1条回答 默认 最新

  • L4mbert 2017-03-21 07:54
    关注

    def login_mysql():
    connection = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='root', db='test')
    return connection

    def exec_sql(sql):
    conn = login_mysql()
    cursor = conn.cursor()
    try:
    cursor.execute(sql)
    exec_result = cursor.fetchall()
    conn.commit()
    conn.close()
    return exec_result
    except:
    conn.rollback()
    conn.close()

    def main():
    sql = 'create table table_name(code varchar(5) not null, %s int(3) not null, %s ...自己构造);' % (name, changepercent)

    # 这里就自己构造一个创建表的语句,根据你获取的字段名自己添加到这里
    result = exec_sql(sql)
    # 我建议你还是提前创建好表,这样操作非常的不好。

    if name == '__main__':
    main()

    评论

报告相同问题?

悬赏问题

  • ¥15 如何在scanpy上做差异基因和通路富集?
  • ¥20 关于#硬件工程#的问题,请各位专家解答!
  • ¥15 关于#matlab#的问题:期望的系统闭环传递函数为G(s)=wn^2/s^2+2¢wn+wn^2阻尼系数¢=0.707,使系统具有较小的超调量
  • ¥15 FLUENT如何实现在堆积颗粒的上表面加载高斯热源
  • ¥30 截图中的mathematics程序转换成matlab
  • ¥15 动力学代码报错,维度不匹配
  • ¥15 Power query添加列问题
  • ¥50 Kubernetes&Fission&Eleasticsearch
  • ¥15 報錯:Person is not mapped,如何解決?
  • ¥15 c++头文件不能识别CDialog