安装扩展
pip3 install mysql-connector-python
连接到MySQL数据库，创建链接对象
conn = mysql.connector.connect(user='root', password='xxx', host='127.0.0.1', database='xxx-database')
创建一个游标对象
cursor = conn.cursor()
查询处理
sql = "SELECT * FROM table WHERE key=%s limit 0,10"
val = ['value']
cursor.execute(sql, val)
# 获取所有记录列表
_result = cursor.fetchall()
遍历查询数据
if _result:
for _row in _result:
# 处理查询结果
print(f"遍历查询ID: {_row[0]}")
新增数据
_sql = "INSERT INTO table (cloumn1, cloumn2, cloumn3) VALUES (%s, %s, %s)"
_val = ('value1', 'value2','value3')
cursor.execute(_sql , _val )
# 获取新增数据的自增主键ID
insert_id = cursor.lastrowid
# 提交更改
conn.commit()
关闭游标和连接
cursor.close()
conn.close()
