import baostock as bs import pandas as pd import pymysql

登陆系统

bs.login()

获取行业分类数据

rs = bs.query_stock_industry()

创建数据库连接

conn = pymysql.connect(host='localhost', port=3306, user='root', password='password', database='baostock')

将结果集插入到数据库表中

cursor = conn.cursor() while (rs.error_code == '0') & rs.next(): industry = rs.get_row_data() sql = "INSERT INTO stock_industry(code, code_name, industry, industry_code, industry_name) VALUES ('%s', '%s', '%s', '%s', '%s')" % (industry[0], industry[1], industry[2], industry[3], industry[4]) cursor.execute(sql)

提交数据库操作并关闭连接

conn.commit() conn.close()

登出系统

bs.logout()