- # 使用python执行SQL
- # 1. 安装pymysql: pip install pymysql
- # 2. 创建到MySQL的数据库链接:
- from pymysql import Connection
-
- # 获取到MySQL数据亏的链接对象
- conn = Connection(
- host='localhost', # 主机名
- port=3306, # 端口
- user='root', # 用户名
- password='123456789' # 密码
- )
-
- # 打印MySQL数据库软件信息
- # print(conn.get_server_info())
-
-
- # 获取游标对象
- cursor = conn.cursor()
-
- # 选择数据库
- conn.select_db("an")
-
- # 使用游标对象,执行SQL语句
- # 执行非查询性质的SQL语句
- # cursor.execute("create table test_pymysql(id int);")
-
- # 使用游标对象,执行SQL语句
- # 执行查询性质的SQL语句
- cursor.execute("select * from singer")
- results = cursor.fetchall()
- # print(results) #((10001, '周杰伦', 31, '男'), (10002, '王力宏', 33, '女'), (10001, '小伦', 13, '男'), (10002, '小宏', 21, '女'), (10003, '小白', 21, '男'), (10004, '小菜', 14, '女'), (10005, '小来', 50, '男'))
- for r in results:
- print(r)
-
- # 关闭到数据库的链接
- conn.close()
注意:pymysql在执行数据插入或其他产生数据更改的SQL语句时,默认是需要提交更改的,即需要通过代码"确认"这种更改行为
通过 链接对象.commit() 即可确认此行为,,或者设置 autocommit=True #自动提交
- # Python执行SQL语句插入数据到MySQL
-
- # pymysql在执行数据插入或其他产生数据更改的SQL语句时,默认是需要提交更改的,即需要通过代码"确认"这种更改行为
- # 通过 链接对象.commit()即可确认此行为
-
- from pymysql import Connection
-
- conn = Connection(
- host="localhost",
- port=3306,
- user="root",
- password="123456789",
- autocommit=True # 自动提交
- )
-
- cursor = conn.cursor()
-
- conn.select_db("singer")
-
- cursor.execute("insert into singer values(10010,'周杰伦',50,'男')")
-
- # conn.commit() # 提交
-
- conn.close()