Python数据库操作----pymysql教学

见贤思齐

文章目录前提准备连接数据库创建数据库创建数据表、插入数据查询数据更新数据删除数据实战应用总结前提准备安装mysql在使用pymysql的前提就是又一个mysql数据库，这个数据库可以是本地数据库也可以是远程的数据库,mysql的安装这里就不再赘述了，大家可以参考其他的模块进行安装安装pymysqlpipinstallpymysql1连接数据库importpymysql#连接数据库db=pymysql.connect(host='localhost',user='root',password='123456',port=3306)#创建数据库的游标cursor=db.cursor()#execute()方法并执行SQL语句cursor.execute("selectversion()")#读取第一条数据data=cursor.fetchone()print(data)#关闭连接db.close()#输出:#('8.0.24',)12345678910111213141516解释：在连接数据的时候需要指定相应的参数host数据库ip地址，如果是本地可以用localhost或127.0.0.1如果是远程就需要指定正确的ip地址user用户名password密码port端口号如果不指定就默认是3306cursor()：获取数据库的操作游标execute()执行SQL语句，把要进操作的内容写成SQL语句，fetchone()读取一条数据close()断开连接，释放资源“selectversion()”sql语句的执行结果创建数据库importpymysql#连接数据库db=pymysql.connect(host='localhost',user='root',password='123456')#创建数据库的游标cursor=db.cursor()#创建数据库spiderscursor.execute("createdatabasespiders")#关闭连接db.close()123456789创建数据库命令执行一次就可以，后面我们在创建的数据库中进行其他的操作，如果创建的数据已经存在程序会报错"Can'tcreatedatabase'spiders';databaseexists"拓展：如果在创建数据库的不能确认数据库是否存在，但是也不想在创建数据库的时候发生报错可以使用下列语句：createdatabaseifnotexistsdbname创建数据表、表必须创建在数据库内，所以我们需要在连接数据库以后，需要指定操作那个数据库importpymysql#连接数据库db=pymysql.connect(host='localhost',user='root',password='123456',port=3306,db='spiders')#创建数据库的游标cursor=db.cursor()sql="createtableifnotexistsstudents(idvarchar(255)notnull,namevarchar(255)notnull,ageintnotnull,primarykey(id))"cursor.execute(sql)db.close()123456789这次的在连接mysql的时候connect函数新增了一个参数，db='spiders'指定我们要连接的数据库，后面创建的表也会创建到当前数据库。创建数据库的sql语句是"createtableifnotexistsstudents(idvarchar(255)notnull,namevarchar(255)notnull,ageintnotnull,primarykey(id))"创建的数据库名为students，三列id、name、age，都是非空，主键为id插入数据importpymysqldb=pymysql.connect(user='root',password='123456',host='localhost',port=3306,db='spiders')cursor=db.cursor()id='10005'name='zhangsan'age='20'#方式1#sql="insertintostudents(id,name,age)values('"+id+"','"+name+"','"+age+"')"#cursor.execute(sql)#方式2#sql="insertintostudents(id,name,age)values('{}','{}','{}')".format(id,name,age)#cursor.execute(sql)#方式3（推荐）sql="insertintostudents(id,name,age)values(%s,%s,%s)"cursor.execute(sql,(id,name,age))db.commit()db.close()123456789101112131415161718通过三种sql语句的编写形式我们能够发现。方式3的最为简洁，通过使用%s来进行占位，然后再通过execute()函数将数据传入sql语句中组成完整的sql语句。在执行execute()方法之后必须要commit()方法才能将数据插入到表中，这个设计到了事务的原子性问题，事务机制可以确保数据一致性，事务有4个属性：原子性、一致性、隔离性、持久性。属性描述原子性事务是一个不可分割的工作单位，事务中包括的操作要么都执行，要么都不执行一致性事务必须是数据库中一个一致性状态转变到另一个一致性状态，一致性与原子性是密切相关的隔离性一个事务不能被其他事务干扰，即一个事务内部的操作及使用的数据对并发的其他事务时隔离的，并发的各个事务之间不能相互干扰持久性持久性也称永久性，指一个事务一旦提交，它对数据库中数据的改变就应该是永久性的，接下来的其他操作或故障不应该对其有任何影响查询数据在数据库操作的过程中使用最多的就是查询操作importpymysqldb=pymysql.connect(user='root',password='123456',host='localhost',port=3306,db='spiders')try:sql='select*fromstudents'cursor=db.cursor()cursor.execute(sql)d1=cursor.fetchone()print("获取一条数据",d1)all_d=cursor.fetchall()print("获取所有数据",all_d)#sql="insertintostudents(id,name,age)values('"+id+"','"+name+"','"+age+"')"except:print("Error")db.close()123456789101112131415数据库中的数据输出：通过结果我们能够看到etchone()执行正常，拿出了一条数据，但是fetchall()明明是查询所有，但是结果只有除了第一条之外的数据，关于这个现象我们可以从游标的角度来解释，一开始游标在第一行执行etchone()之后游标就跑到第二行，再执行fetchall()的时候就从第二行开始查询直至末尾。可以简单的理解etchone()查询游标所在的一行数据，fetchall()查询当前游标至结束的所有行数据。使用where进行条件查询查询id大于10003的数据importpymysqldb=pymysql.connect(user='root',password='123456',host='localhost',port=3306,db='spiders')try:sql='select*fromstudentswhereid>10003'cursor=db.cursor()cursor.execute(sql)all_d=cursor.fetchall()print("获取所有数据",all_d)#sql="insertintostudents(id,name,age)values('"+id+"','"+name+"','"+age+"')"except:print("Error")db.close()12345678910111213输出：更新数据跟新数据，有时候我们再会对数据库中原来的数据进行修改importpymysqldb=pymysql.connect(user='root',password='123456',host='localhost',port=3306,db='spiders')try:sql='updatestudentssetname=%swhereid=%s'cursor=db.cursor()cursor.execute(sql,('李四','10004'))db.commit()except:db.rollback()db.close()1234567891011删除数据根据条件删除数据，删除id小于10004的数据importpymysqldb=pymysql.connect(user='root',password='123456',host='localhost',port=3306,db='spiders')try:sql='deletefromstudentswhereid