title:Example
collapse:open
获取数据库连接
conn = Connection(
host = 'localhost', # or: IP地址
port = 3306, # 端口
user = 'root', # 账户名
password = '123456'
[,autocommit = True] # 自动确认更新数据
)
title:Example
collapse:open
获取游标对象
cursor = conn.cursor()
conn.select_db("test")
# 使用游标对象,执行sql语句
cursor.execute("CREATE TABLE test_pymysql(id INT, info VARCHAR(255))")
# 关闭数据库
conn.close()
title:Example
collapse:open
获取查询结果
# from 获取数据库连接
cursor = conn.cursor()
conn.select_db("test")
cursor.execute("SELECT * FROM student")
# 获取查询结果
results: tuple = cursor.fetchall()
for r in results:
print(r)
# 关闭数据库
conn.close()
# output:
((456654, 'ewfw', 32), (...), (...))
title:Example
collapse:open
更改数据
确认更新数据
`commit`
# from 获取数据库连接
cursor = conn.cursor()
conn.select_db("test")
cursor.execute("INSERT INTO student values(10001, '周杰伦', 31, '男')")
# commit确认
conn.commit()
conn.close()