增减改删¶
删¶
- 建立连接:
con = pymysql.connect(host="8.147.233.239", user="root", password="team2111", database="ryp", port=3306, charset='utf8')
这里创建了一个数据库连接,参数包括主机地址(host)、用户名(user)、密码(password)、要连接的数据库名(database)、端口(port)以及字符集(charset)。
- 创建游标对象:
游标对象用于执行SQL语句并返回结果。
- 编写SQL语句:
SQL语句是用来删除book表中name字段等于给定值的数据,这里使用占位符 %s
来避免SQL注入风险。
- 执行SQL语句:
使用游标对象的execute方法执行SQL语句,传入SQL语句和参数元组。
- 提交事务:
如果执行成功,会将更改提交到数据库。
- 异常处理:
如果执行过程中遇到异常,会捕获异常并打印出来,然后回滚事务以撤销更改。
- 关闭资源:
改¶
- 连接数据库1:
Python
db = pymysql.connect(
host='8.147.233.239', # 你的MySQL服务器地址
user='root', # 数据库用户名
password='team2111', # 数据库密码
port=3306, # 端口(默认通常为3306)
charset='utf8',
database='ryp' # 你想使用的数据库名
)
- 创建表格:
Python
table_name = "book"
sql = f"CREATE TABLE `{table_name}` (id VARCHAR(20) NOT NULL, name VARCHAR(20) NOT NULL, PRIMARY KEY(id))"
cursor.execute(sql)
- 查询和显示表信息:
Python
sql = 'show tables;' # 显示所有表
cursor.execute(sql)
print("显示创建的表:", cursor.fetchall())
sql = 'desc {}'.format(table_name) # 描述指定表的结构
cursor.execute(sql)
print("显示表的结构:", cursor.fetchall())
- 关闭连接:
查¶
import pymysql
导入pymysql库,用于与MySQL数据库交互。con = pymysql.connect()
创建数据库连接,参数包括服务器地址、用户名、密码、数据库名、端口(默认3306)以及字符编码(utf8)。cur = con.cursor()
创建一个游标对象,用于执行SQL命令并返回结果。- 定义SQL查询语句
sql = "select * from book_info where book_name='《C#入门经典》'"
,这会选取book_info
表中书名字段等于指定名称的记录。 try:
开始一个异常处理块,尝试执行SQL查询:cur.execute(sql)
执行SQL查询。book = cur.fetchone()
获取第一条匹配的数据行。- 如果查询成功,打印查询结果的每一项(假设表中有五个字段:book_line_isbn、book_name、author、abs),并分别赋值给对应的变量。
except Exception as e:
捕获执行过程中可能出现的任何异常,打印异常信息,并显示“查询所有数据失败”。- 最后,在
finally:
块中关闭游标 (cur.close()
) 和数据库连接 (con.close()
),以释放资源,无论是否发生异常。