快捷搜索:  汽车  科技

pythonmysql数据处理(Python操作mysql数据库)

pythonmysql数据处理(Python操作mysql数据库)这个一目了然,fetchall()就是全部结果 这个返回结果是一个大元组,里面都是一个个小元组import pymysql #建立连接 conn=pymysql.connect( host='127.0.0.1' port=3306 user='Huterox' passwd='865989840' db='huterox' charset='utf8' ) cursor = conn.cursor() try: Sqlcomm = """select name as 名字 age as 年龄 heigh as 身高 from hello""" cursor.execute(Sqlcomm) for row in

建立数据连接

其实使用pymysql进行数据库的连接是非常简单的,第一步就是建立数据库连接(在python当中,这其实更像是使用了一个代理)

import pymysql try: #建立连接 conn=pymysql.connect( host='127.0.0.1' port=3306 user='Huterox' passwd='passwd' db='huterox' charset='utf8' ) except pymysql.Error as err: print(err) 复制代码操作流程

下面为了更好的理解相关操作,请看下面的流程图,它将很好地反映这个pymysql的操作方式。

pythonmysql数据处理(Python操作mysql数据库)(1)

使用游标执行sql语句数据 增,删除,改

这个数据的查询和这几个是不太一样的,说以下面再说。 先展示以先当前的演示环境

pythonmysql数据处理(Python操作mysql数据库)(2)

现在我们在这里面插入数据

Sqlcomm = """insert into hello(name age) value(%s %s)""" cursor.execute(Sqlcomm ("xx" 15)) 复制代码

import pymysql #建立连接 conn=pymysql.connect( host='127.0.0.1' port=3306 user='Huterox' passwd='865989840' db='huterox' charset='utf8' ) cursor = conn.cursor() try: Sqlcomm = """insert into hello(name) value(%s)""" cursor.execute(Sqlcomm ("小刚")) conn.commit()#提交 except pymysql.Error as err: conn.rollback()#回滚 print(err) finally: conn.close() 复制代码

pythonmysql数据处理(Python操作mysql数据库)(3)

现在已经加入了,这一条,那么现在添加age和heigh的值

update hello set age=15 heigh=185 where name=%s 复制代码

import pymysql #建立连接 conn=pymysql.connect( host='127.0.0.1' port=3306 user='Huterox' passwd='865989840' db='huterox' charset='utf8' ) cursor = conn.cursor() try: Sqlcomm = """update hello set age=15 heigh=185 where name=%s""" res = cursor.execute(Sqlcomm ("小刚")) if res==1: #一条受影响,返回一 print("修改成功") conn.commit()#提交 except pymysql.Error as err: conn.rollback()#回滚 print(err) finally: conn.close() 复制代码

pythonmysql数据处理(Python操作mysql数据库)(4)

接下来就是删除了,那还不简单

delete from hello where name=’小刚‘ 复制代码

pythonmysql数据处理(Python操作mysql数据库)(5)

数据的查找

这个就有点区别了 看代码

import pymysql #建立连接 conn=pymysql.connect( host='127.0.0.1' port=3306 user='Huterox' passwd='865989840' db='huterox' charset='utf8' ) cursor = conn.cursor() try: Sqlcomm = """select name as 名字 age as 年龄 heigh as 身高 from hello""" cursor.execute(Sqlcomm) for row in cursor.fetchall(): print(row) conn.commit()#提交 except pymysql.Error as err: conn.rollback()#回滚 print(err) finally: conn.close() 复制代码

cursor 有三个方法获取结果

pythonmysql数据处理(Python操作mysql数据库)(6)

这个一目了然,fetchall()就是全部结果 这个返回结果是一个大元组,里面都是一个个小元组

pythonmysql数据处理(Python操作mysql数据库)(7)

那么在这里的化还可以设置为字典,也最好设置为字典。

conn=pymysql.connect( host='127.0.0.1' port=3306 user='Huterox' passwd='pw' db='huterox' charset='utf8' cursorclass=pymysql.cursors.DictCursor ) 复制代码

pythonmysql数据处理(Python操作mysql数据库)(8)

注入防范

这个在pymysql里面比较好的就是它会帮助我们自己完成防范,你只需要,把变量,也就是用户输入当作元组在execute()函数中放置,而不是在字符串里面拼接即可。

pythonmysql数据处理(Python操作mysql数据库)(9)

猜您喜欢: