import pymysql
# 创建连接
connection = pymysql.connect(
host='localhost', # 数据库主机地址
user='your_username', # 数据库用户名
password='your_password', # 数据库密码
database='your_database', # 数据库名称
charset='utf8mb4', # 字符编码
cursorclass=pymysql.cursors.DictCursor # 使用字典游标
)
try:
with connection.cursor() as cursor:
# 创建一个表
create_table_query = """
CREATE TABLE IF NOT EXISTS users (
id INT AUTO_INCREMENT PRIMARY KEY,
username VARCHAR(50) NOT NULL,
email VARCHAR(100) NOT NULL
)
"""
cursor.execute(create_table_query)
# 插入数据
insert_query = "INSERT INTO users (username, email) VALUES (%s, %s)"
cursor.execute(insert_query, ('Alice', 'alice@example.com'))
# 查询数据
select_query = "SELECT * FROM users"
cursor.execute(select_query)
result = cursor.fetchall()
print(result) # 打印查询结果
# 提交事务
connection.commit()
finally:
# 关闭连接
connection.close()
pymysql.connect()
方法创建与 MySQL 数据库的连接,传入主机地址、用户名、密码、数据库名称等参数。CREATE TABLE IF NOT EXISTS
语句创建一个名为 users
的表,包含 id
、username
和 email
列。INSERT INTO
语句向 users
表中插入一条记录。SELECT
语句查询 users
表中的所有记录,并通过 fetchall()
方法获取查询结果。connection.commit()
提交事务,确保插入的数据被保存到数据库中。finally
块中关闭数据库连接,确保资源释放。上一篇:mysqlexplain
Laravel PHP 深圳智简公司。版权所有©2023-2043 LaravelPHP 粤ICP备2021048745号-3
Laravel 中文站