- 安装pymysql包：
pip install --upgrade pip # 更新pip
pip install PyMySQL==0.9.3
- 创建连接，查询数据库：
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()方法后影响的行数。
- 传入字典插入数据：
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()
- 其他数据库操作，替换数据库sql语句即可。
