import MySQLdb
# 连接到MySQL数据库
def connect_to_db():
try:
# 创建连接
db = MySQLdb.connect(
host="localhost", # 数据库主机地址
user="root", # 数据库用户名
passwd="password", # 数据库密码
db="testdb" # 数据库名称
)
return db
except MySQLdb.Error as e:
print(f"Error connecting to MySQL Platform: {e}")
return None
# 插入数据到表中
def insert_data(db, table, data):
cursor = db.cursor()
try:
# 构建SQL语句
sql = f"INSERT INTO {table} (name, age) VALUES (%s, %s)"
cursor.execute(sql, (data['name'], data['age']))
db.commit() # 提交事务
print("Data inserted successfully")
except MySQLdb.Error as e:
db.rollback() # 如果发生错误则回滚
print(f"Error inserting data: {e}")
# 查询数据
def query_data(db, table):
cursor = db.cursor()
try:
# 执行查询语句
cursor.execute(f"SELECT * FROM {table}")
results = cursor.fetchall() # 获取所有记录
for row in results:
print(row)
except MySQLdb.Error as e:
print(f"Error querying data: {e}")
# 主函数
if __name__ == "__main__":
db = connect_to_db()
if db:
data = {'name': 'Alice', 'age': 30}
insert_data(db, 'users', data)
query_data(db, 'users')
db.close() # 关闭数据库连接
connect_to_db 函数用于创建与 MySQL 数据库的连接。需要提供主机地址、用户名、密码和数据库名称。insert_data 函数用于向指定表中插入数据。通过构建 SQL 插入语句并执行,确保数据正确插入。query_data 函数用于从指定表中查询所有数据,并打印每一行记录。__main__ 中,先连接数据库,然后插入一条数据,接着查询并打印所有数据,最后关闭数据库连接。这个示例代码展示了如何使用 mysqlclient 库进行基本的数据库操作。请根据实际情况修改主机地址、用户名、密码和数据库名称。
上一篇:mysql约束
下一篇:mysql set global
Laravel PHP 深圳智简公司。版权所有©2023-2043 LaravelPHP 粤ICP备2021048745号-3
Laravel 中文站