mysql-python3连接、操作数据库

1. 安装pymysql包：

pip install --upgrade pip  # 更新pip
pip install PyMySQL==0.9.3

2. 创建连接，查询数据库：

import pymysql

sql = """select DISTINCT id_test FROM table_test"""
MYSQL_TEST = {
    'host': '127.0.0.1',
    'user': 'root',
    'passwd': '123456',
    'db': 'db_test',
    'charset': 'utf8'
}
db = pymysql.connect(**MYSQL_TEST)
cursor = db.cursor()
cursor.execute(sql)
set_test = cursor.fetchall()
sursor.close()
db.close()

• 注：
• fetchone(): 该方法获取下一个查询结果集。结果集是一个对象
• fetchall(): 接收全部的返回结果行.
• rowcount: 这是一个只读属性，并返回执行execute()方法后影响的行数。

3. 传入字典插入数据：

import pymysql
    
MYSQL_TEST = {
    'host': '127.0.0.1',
    'user': 'root',
    'passwd': '123456',
    'db': 'db_test',
    'charset': 'utf8'
}

db = pymysql.connect(**MYSQL_TEST)
cursor = db.cursor()

insert_dict = {
        "id": "test123",
        "name": "tets456",
    }
sql = "insert into boardid_info (" + ','.join(insert_dict) + ") values (\'%("+')s\',\'%('.join(insert_dict)+")s\')"

try:
    cursor.execute(sql % insert_dict)
    db.commit()       # 提交到数据库执行
except:
    db.rollback()        # 如果发生错误则回滚
db.close()

4. 其他数据库操作，替换数据库sql语句即可。