前言
(sql部分的笔记较多难以整理,先简单说明一下如何使用python进行数据库连接,此外由于Java的技术栈过长,接下来的学习将重新回归到python先实现效果,之后再使用Java进行实现,做进一步的优化)
利用Python来实现数据库的连接的话,其实很简单,我们主流使用的第三方库是pymysql这是一个使用python来实现的第三方库,当然在不同的框架中可以直接调用相关使用数据库的方法。那么这里先简单说一下怎么使用pymysql实现数据库的连接。
建立数据连接
其实使用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的操作方式。
使用游标执行sql语句
数据 增,删除,改
这个数据的查询和这几个是不太一样的,说以下面再说。
先展示以先当前的演示环境
现在我们在这里面插入数据
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()
现在已经加入了,这一条,那么现在添加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()
接下来就是删除了,那还不简单
delete from hello where name=’小刚‘
数据的查找
这个就有点区别了
看代码
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 有三个方法获取结果
这个一目了然,fetchall()就是全部结果
这个返回结果是一个大元组,里面都是一个个小元组
那么在这里的化还可以设置为字典,也最好设置为字典。
conn=pymysql.connect(
host='127.0.0.1',port=3306,user='Huterox',
passwd='pw',db='huterox',charset='utf8',
cursorclass=pymysql.cursors.DictCursor
)
注入防范
这个在pymysql里面比较好的就是它会帮助我们自己完成防范,你只需要,把变量,也就是用户输入当作元组在execute()函数中放置,而不是在字符串里面拼接即可。