Python连接MySQL数据库进行增删查改

66 阅读 0 评论 44 点赞

我是靠谱客的博主安静帅哥，最近开发中收集的这篇文章主要介绍Python连接MySQL数据库进行增删查改，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

1.连接数据库

我是用的python版本是3.6.6，就得先安装PyMySQL模块；

如果是Python2中则使用mysqldb模块，也需先安装。

安装PyMySQL：

C:Usersasus>pip3 install PyMySQL

Collecting PyMySQL

Downloading https://files.pythonhosted.org/packages/a7/7d/682c4a7da195a678047c8f1c51bb7682aaedee1dca7547883c3993ca9282/PyMySQL-0.9.2-py2.py3-none-any.whl (47kB) 100% |████████████████████████████████| 51kB 104kB/s

开始使用：

import pymysql

#打开数据库连接
db = pymysql.connect('192.168.1.103','root','mysql','py_peewee')

插入数据前确保数据库中已经存在相应的table

插入一条数据：

import pymysql #引入模块

#打开数据库连接
db = pymysql.connect('192.168.1.103','root','mysql','py_peewee')
#创建一个游标
cursor = db.cursor()
sql_insert="INSERT INTO person(NAME,PASSWD,EMAIL,GENDER,BIRTHDAY,IS_ADMIN)" 
    "VALUES('Asda','12321','AsSs@33',2,STR_TO_DATE('06/05/2017','%m/%d/%Y'),TRUE)"
#执行sql语句
cursor.execute(sql_insert)
# 提交到数据库执行
db.commit() #进行提交

条件查找语句

import pymysql

#打开数据库连接
db = pymysql.connect('192.168.1.103','root','mysql','py_peewee')
cursor = db.cursor()

sql = "select * from person where is_admin=true"
cursor.execute(sql)
#fetchall() 查询结果为多行数据，fetchone()函数之获取一条数据，结果是个对象
results = cursor.fetchall()
#结果类型
print(type(results))
#通过控制台可以看到results的类型是<class 'tuple'>元组，所以通过操作tuple方式操作查询结果，而且内部元素也是tuple
# print(results[0])
# print(results[1])
# print(results[2])
#循环输出
for row in results:
    print(row[0])
    print(row[1])
    print(row[2])
    print(row[3])
#关闭连接    
db.close()

删除操作：

import pymysql

#打开数据库连接
db = pymysql.connect('192.168.1.103','root','mysql','py_peewee')
cursor = db.cursor()

sql = "DELETE  from person where id=2"
cursor.execute(sql)
db.commit()
#关闭连接
db.close()

修改操作：

import pymysql

#打开数据库连接
db = pymysql.connect('192.168.1.103','root','mysql','py_peewee')
cursor = db.cursor()

sql = "update person SET name='ppp' where name='ab'"
cursor.execute(sql)
db.commit()
#关闭连接
db.close()

以上的操作方式都是比较简单底层的，没有引入框架，有点类似Java的JDBC操作

同时上面的sql执行方式与Java的Statement对象相同，都是进行sql字符串拼接，存在sql注入漏洞