python 使用pymysql连接daily,读取每一张表,并且给每一张表格增加两列,表名格式: 000001.SZ 列名是a和b,如果a和b列存在,则跳过
时间: 2023-12-22 08:05:55 浏览: 128
好的,我可以帮您解决这个问题。首先,您需要安装`pymysql`模块,可以使用以下命令进行安装:
```
pip install pymysql
```
然后,您可以使用以下代码连接daily,并读取每一张表:
```python
import pymysql
connection = pymysql.connect(host='your_host', user='your_user', password='your_password', database='your_database')
cursor = connection.cursor()
# 获取所有表名
cursor.execute("SHOW TABLES")
tables = cursor.fetchall()
for table in tables:
table_name = table[0]
# 判断表名是否符合要求
if table_name.endswith('.SZ'):
# 添加两列
cursor.execute(f"ALTER TABLE {table_name} ADD COLUMN a VARCHAR(255), ADD COLUMN b VARCHAR(255)")
connection.commit()
cursor.close()
connection.close()
```
在上面的代码中,`your_host`、`your_user`、`your_password`、`your_database`分别表示您的数据库主机、用户名、密码和数据库名。`SHOW TABLES`语句可以获取所有表名,然后使用`ALTER TABLE`语句向每个表中添加两列。如果表已经存在`a`和`b`列,则不会重复添加。最后,使用`commit()`方法提交更改,关闭游标和连接。
阅读全文