首先需要导入驱动模块

打开cmd导入模块 pip install mysqldb(pymysql)

python2.x版本--------->mysqldb

python3.x版本---------->pymysql

python调用MySQL数据库总共五步

1、导入模块(驱动) pymysql  mysqldb

2、获取连接 connect

3、获取游标cursor

4、执行sql execute 并且返回结果

5、关闭资源

====================================================================

#python 调用mysql帮助类  连接数据库 创建数据查询更新的方法

#创建一个数据库帮助类

#导入pymysql模块

import pymysql

#创建类

class sqlHelper:

#初始化属性

def __init__(self,host,db,user,pwd):

self.host = host

self.port = 3306

self.db = db

self.user = user

self.pwd = pwd

self.charset = 'utf8'

#创建数据库连接 创建游标

def connection(self):

self.conn = pymysql.connect(host = self.host,port = self.port,db = self.db,user = self.user,

password = self.pwd,charset = self.charset)

self.cursor = self.conn.cursor()

return 'OK'

#创建查询一条数据的方法

def queryOne(self,sql,params):

#首先连接数据库 获取游标

try:

self.connection()

#执行sql语句

count = self.cursor.execute(sql,params)

#返回执行结果

res = self.cursor.fetchone()

return  count,res

except Exception as  ex:

print('失败,失败信息是:',ex)

finally:

#调用关闭资源的方法

self.closes()

#创建查询多条数据的方法

def queryAll(self,sql,params):

try:

#连接数据库

self.connection()

#执行sql语句

count = self.cursor.execute(sql,params)

#获取结果

res = self.cursor.fetchall()

return count,res

except Exception as e:

print('查询失败 失败信息是：',e)

finally:

#调用关闭资源的方法

self.closes()

#创建修改数据库的方法

def update(self,sql,params):

try:

# 连接数据库

self.connection()

# 执行sql语句

count = self.cursor.execute(sql,params)

#把事物(更新的信息写入数据库)

self.conn.commit()

return count

except Exception as e:

print('查询失败 失败信息是：', e)

#如果更新失败 数据库就返回到更新之前的数据

self.conn.rollback()

finally:

# 调用关闭资源的方法

self.closes()

#定义关闭资源的方法

def closes(self):

if self.cursor != None:

self.cursor.close()

if self.conn != None:

self.conn.close()

================================================================================================

测试数据库帮助类的文档：

'''

python调用mysql分为五个步骤

1、导入pymysql模块

2、获取连接 connect

3、获取游标 curs

4、执行SQL execute 并返回结果

5、关闭资源

'''

#定义用户操作数据库的一些方法

import sqlHelper

import sys

#创建连接对象  host,db,user,pwd

helper = sqlHelper.sqlHelper('localhost','db_py1712','root','root')

#print(helper.connection())

# a,s = helper.queryOne('select * from t_stumessage',[])

# print(s)

# a = helper.update('insert into t_stumessage VALUES (uuid() ,%s,%s,%s,%s,%s)',['陈乐乐',123456,21,'男','万方学院'])

# print(a)

# a,s = helper.queryAll('select * from t_stumessage',[])

# print(s)

#用户注册

def register(user):

#首先查询数据库中是否存在该用户名

#查询表中所有用户名

count,res = helper.queryAll('select username from t_stumessage',[])

#遍历元组 判断输入的用户名是否存在

bn = False

for u in res:

# print(u)

# print(type(u))

if u[0] != user:

bn = True

if bn == False:

pwd = int(input('请输入密码'))

age = int(input('请输入年龄'))

sex = input('请输入性别')

school = input('请输入学校名称')

#把用户输入的信息写如到数据库表中

# s = helper.connection()

# print(s)

count = helper.update('insert into t_stumessage VALUES (uuid() ,%s,%s,%s,%s,%s)',[user,pwd,age,sex,school])

if count > 0:

print('注册成功')

else:

print('注册失败')

else:

print('你输入的用户名已经存在，请重新输入')

#register('王少松')

#用户登录

def login(user,pwd):

#查询表中的用户名和密码 判断与用户输入的信息是否匹配

count,res = helper.queryAll('select username,pwd from t_stumessage ',[])

return count,res

#遍历res

# bn = False

# for u in res:

#    if u[0] == user and u[1] == pwd:

#        bn =True

# if bn == True:

#    print('登录成功')

# else:

#    print('用户名或密码错误，登录失败')

# u = input()

# s = input()

# login(u,s)

#用户列表 根据用户名查看用户自己的基本信息

def messages(user):

count,res = helper.queryOne('select * from t_stumessage where userName = %s',(user,))

return count,res

# if count > 0:

#    return res

# else:

#    print('查询失败')

#messages('赵娇娇')

#用户修改  根据用户名修改密码

def update(user,pwd):

count = helper.update('update t_stumessage set pwd = %s WHERE username = %s',[pwd,user])

#print(count)

if count > 0:

print('修改成功')

else:

print('修改失败')

#update('赵娇娇','123123')

#用户删除 根据用户名删除用户信息

def dels(user):

count = helper.update('delete from t_stumessage WHERE username = %s',(user,))

if count > 0:

print('删除成功')

else:

print('删除失败')

#dels('赵娇娇')

#用户退出

def exit():

print('退出')

sys.exit()

#exit()

========================================================================