礦工代碼篇(2)：Python插入資料庫mysql

很多時候Python在數據處理和計算上不是太方便，可以用資料庫來操作統計。具體的方式就是通過pymysql這個第三方庫。

pip install pymysql

具體連接資料庫和操作資料庫都很簡單：

#coding=utf-8import timeimport pymysqlconn = pymysql.connect( host=127.0.0.1, port=3306, user=root, passwd=12345, db=mysql, )cur = conn.cursor()cur.execute("create table if not EXISTS qy_stock_option_vol_20d(code VARCHAR (100),close_price VARCHAR(20),vol_price VARCHAR (20),ds VARCHAR (10))")todayformat=str(time.strftime(%Y%m%d,time.localtime(time.time())))filename_20d=/usr/local/bin/python_data/stockvol_20d_+todayformat+.txtf = open(filename_20d, "r")while True: for line in f.readlines(): if not line.strip():continue #處理每行
line = line.strip(
) line = line.strip([) line = line.strip(]) line = line.strip( ) line = line.split(,) #print(line[0]) code = line[0] close_price = line[1] vol_price = line[2] cur.execute("insert into qy_stock_option_vol_20d(code,close_price,vol_price,ds) values(%s,%s,%s,%s)",[code, close_price, vol_price, todayformat]) else: breakf.close()cur.close()conn.commit()conn.close()

http://weixin.qq.com/r/V3XUzBbEm0vkrVKv9yBF (二維碼自動識別)

推薦閱讀：