MySQL系列--4.使用Python3访问数据库
程序员文章站
2022-07-27 16:53:00
使用Python3操作MySQL数据库:创建表,插入数据,查询数据,更新数据,删除数据。 ......
1、安装mysql驱动
pip install mysql-connector
安装完成后进入命令行模式,导入驱动,如果不报错,说明安装成功
python 3.6.7 (default, oct 22 2018, 11:32:17) [gcc 8.2.0] on linux type "help", "copyright", "credits" or "license" for more information. >>> import mysql.connector >>>
2、安装mysql
mysql安装请参考:https://www.cnblogs.com/webdepofqws/p/10685617.html
3、操作数据库
mysql操作数据库的一般步骤如下:
a、建立连接
b、通过连接对象得到游标对象
c、执行sql语句,获取执行结果,如果执行的sql语句会改变数据库或表 ,需要提交,才会保存修改。
d、关闭游标对象,关闭连接对象。
创建表并插入数据
在rms数据库中创建一张表:user_info并插入2条数据,创建表sql语句如下:
create table user_info( id int(10) primary key, name char(20) not null, passwd char(40) not null, email char(20) not null, phone char(20) not null, role char(10) not null, sex char(10) not null, status int(10) not null, createat datetime not null, exprat datetime not null, validdays int(10) not null, delat datetime )engine=innodb default charset=utf8;
python3代码:
#coding:utf-8 #导入驱动 import mysql.connector #建立连接 conn = mysql.connector.connect(host="127.0.0.1",user='root',database='rms',password='password') #获游标标对象 cursor = conn.cursor() #sql语句 sql1='''create table user_info( id int(10) primary key, name char(20) not null, passwd char(40) not null, email char(20) not null, phone char(20) not null, role char(10) not null, sex char(10) not null, status int(10) not null, createat datetime not null, exprat datetime not null, validdays int(10) not null, delat datetime )engine=innodb default charset=utf8;''' sql2='''insert into user_info values (1,"stephenwang7","123456","123@qq.com","15103887470","admin","male","200","20190412201130","20190419201130",30,null)''' try: #执行创建表的sql语句 cursor.execute(sql1) #执行插入语句 cursor.execute(sql2) #提交 conn.commit() except exception as e: print(e) finally: #关闭游标对象 cursor.close() #关闭连接 conn.close
连接数据库查看结果:
mysql> select count(*) from user_info; +----------+ | count(*) | +----------+ | 2 | +----------+ 1 row in set (0.27 sec) mysql>
查询sql执行结果
fetchone():返回一条结果。
fetchall():返回所有结果。
fetchmany([size]):返回size条结果。
示例1:
try: cursor.execute("select count(*) from user_info;") #获取执行结果 result = cursor.fetchone() print(result) except exception as e: print(e)
输出1:
#返回的是一个tuple (2,)
示例2:
查询user_info表中所有的记录。
try: cursor.execute("select count(*) from user_info;") #获取执行结果,fatchone 只返回一条结果 result = cursor.fetchone() print(result) except exception as e: print(e)
运行示例2的代码时,报错:unread result found,在连接数据库时设置'buffered': true。
conn = mysql.connector.connect(host="127.0.0.1",user='root',database='rms',password='password',buffered=true)
输出2:
(1, 'stephenwang7', '123456', '123@qq.com', '15103887470', 'admin', 'male', 200, datetime.datetime(2019, 4, 12, 20, 11, 30), datetime.datetime(2019, 4, 19, 20, 11, 30), 30, none)
更新和删除
更新和删除的代码与创建表类似,需要说明的一点是执行语句之后需要提交(commmit)。
#coding:utf-8 #导入驱动 import mysql.connector #建立连接 conn = mysql.connector.connect(host="127.0.0.1",user='root',database='rms',password='password',buffered=true) #获游标标对象 cursor = conn.cursor() try: #执行更新语句 cursor.execute("update user_info set passwd=%s where id=%s",['py123456',1]) #获取执行结果 result = cursor.fetchone() print(result) #提交 conn.commit() except exception as e: print(e) finally: #关闭游标对象 cursor.close() #关闭连接 conn.close
mysql的占位符为%s,连接数据库查看结果:
mysql> select passwd from user_info where id=1; +----------+ | passwd | +----------+ | py123456 | +----------+ 1 row in set (0.03 sec)
上一篇: Linux网络——修改配置文件
推荐阅读
-
python使用MySQLdb访问mysql数据库的方法
-
docker中使用mysql数据库详解(在局域网访问)
-
Django系列---使用MySql数据库
-
docker中使用mysql数据库详解(在局域网访问)
-
使用ASP.NET Web Api构建基于REST风格的服务实战系列教程——使用Repository模式构建数据库访问层
-
Spring Boot入门(七):使用MyBatis访问MySql数据库(xml方式)
-
MySQL系列--4.使用Python3访问数据库
-
Spring Boot入门(六):使用MyBatis访问MySql数据库(注解方式)
-
docker中使用mysql数据库实现局域网访问
-
如果在本地搭一个服务器和mysql数据库环境,如果使用java来访问_MySQL