pymysql使用

安装

pip install pymysql

import pymysql

数据库配置

MYSQL_CONF = {
    "host": "ip地址或域名",
    "user": "root",
    "password": "密码",
    "db": "数据库名"
}

连接数据库

# 连接数据库
mysql_con = pymysql.connect(**MYSQL_CONF)

# 真正执行语句的线程
mysql_cursor = mysql_con.cursor()

执行SQL语句

• 单条执行

SQL = f"""
    insert into table_name (key1, key2, key3)
        values ('{value1}', {value2}, '{value3}') 
"""
mysql_cursor.execute(SQL)
        
# 显示执行commit, 避免cursor执行，但是数据库没有收到执行指令
mysql_con.commit()

• 多条执行(如果其中有一条报错，那么整个会回滚)

values = [
    (value1, value2, value3),
    (value1, value2, value3),
    (value1, value2, value3),
    (value1, value2, value3),
]
SQL = """
    insert into table_name (key1, key2, key3)
        values (%s, %s, %s) 
"""
mysql_cursor.executemany(SQL, values)
mysql_con.commit()

• 获取返回值

SQL = """select key1, key2 from table_name"""
mysql_cursor.execute(SQL)
# 获取返回值
query_set = mysql_cursor.fetchall()

返回的是一个元组，元组中表示记录的也是一个元组