MySQL与Python交互

Posted 2021-01-04 薄荷味日记

一、安装mysql

二、安装第三方模块（python2.7下）

三、新建数据库

四、数据库的增、删、改、查

五、封装

 

1.1 首先安装mysql

sudo apt-get install mysql-server mysql-client

1.2 mysql的启动、停止、重启

service mysql start
service mysql stop
service mysql restart

1.3 允许远程连接

1.找到mysql配置文件并修改
sudo vi /etc/mysql/mysql.conf.d/mysqld.cnf
# bind-address=127.0.0.1
2.登录mysql，运行命令 
grant all privileges on *.* to ‘root‘@‘%‘ identified by ‘mysql‘ with grant option;
flush privileges;
3.重启 mysql

 

2.1 安装mysql模块

sudo pip install MySQL-python

pip install pymysql（python3）

2.2 建立与数据库的连接

1.创建对象：调用connect()方法
conn=connect(参数列表)

• 参数host：连接的mysql主机，如果本机是‘localhost‘
• 参数port：连接的mysql主机的端口，默认是3306
• 参数db：数据库的名称
• 参数user：连接的用户名
• 参数password：连接的密码
• 参数charset：通信采用的编码方式，默认是‘gb2312‘，要求与数据库创建时指定的编码一致，否则中文会乱码

2.3 对象的方法

• close()关闭连接
• commit()事务，所以需要提交才会生效
• rollback()事务，放弃之前的操作
• cursor()返回Cursor对象，用于执行sql语句并获得结果

　　执行sql语句

　　创建对象：调用Connection对象的cursor()方法
　　cursor1=conn.cursor()

• close()关闭
• execute(operation [, parameters ])执行语句，返回受影响的行数
•  fetchone()执行查询语句时，获取查询结果集的第一个行数据，返回一个元组
• next()执行查询语句时，获取当前行的下一行
•  fetchall()执行查询时，获取结果集的所有行，一行构成一个元组，再将这些元组装入一个元组返回
• scroll(value[,mode])将行指针移动到某个位置
  • mode表示移动的方式
  • mode的默认值为relative，表示基于当前行移动到value，value为正则向下移动，value为负则向上移动
  • mode的值为absolute，表示基于第一条数据的位置，第一条数据的位置为0

2.4 对象的属性

• rowcount只读属性，表示最近一次execute()执行后受影响的行数
• connection获得当前连接对象

 

3.1 在student数据库中新建users表

使用sha1加密

create table users(
    id int primary key auto_increment,
    uname varchar(20),
    upwd char(40),
    isdelete bit default 0
);

3.2 加入测试数据

INSERT INTO users(`id`, `uname`, `upwd`, `isdelete`) VALUES (1, ‘user1‘, ‘40bd001563085fc35165329ea1ff5c5ecbdbbeef‘, b‘0‘);
INSERT INTO users(`id`, `uname`, `upwd`, `isdelete`) VALUES (2, ‘user2‘, ‘51eac6b471a284d3341d8c0c63d0f1a286262a18‘, b‘0‘);

 

4.1 增加、修改、删除

 1  # encoding=utf-8
 2  import MySQLdb
 3  
 4  try:
 5      conn = MySQLdb.connect(host=‘localhost‘, port=3306, db=‘student‘, user=‘root‘, passwd=‘root‘, charset=‘utf8‘)
 6      cur = conn.cursor()
 7  # 增加
 8  　　sql1 = "insert into users(id,uname) values(3,‘张三‘)"
 9  # 修改
10  # sql = "update users set uname=‘李四‘ where id=4"
11  # 删除
12  # sql = "delete from users where id=5"
13      count = cur.execute(sql)
14      conn.commit()
15      cs1.close()
16      conn.close()
17  except Exception as e:
18     print e.message

 4.2 查询

1. 查询一行数据
#encoding=utf8
import MySQLdb
try:
  conn=MySQLdb.connect(host=‘localhost‘,port=3306,db=‘student‘,user=‘root‘,passwd=‘mysql‘,charset=‘utf8‘)
    cur=conn.cursor()
    cur.execute(‘select * from users where id=1‘)
    result=cur.fetchone()
    print result
    cur.close()
    conn.close()

except Exception,e:
    print e.message


2. 查询多行数据
#encoding=utf8
import MySQLdb
try:
    conn=MySQLdb.connect(host=‘localhost‘,port=3306,db=‘student‘,user=‘root‘,passwd=‘mysql‘,charset=‘utf8‘)
    cur=conn.cursor()
    cur.execute(‘select * from users‘)
    result=cur.fetchall()
    print result
    cur.close()
    conn.close()
except Exception,e:
    print e.message

 

 5.1  封装

# encoding=utf8
import MySQLdb
import hashlib


class MysqlHelper():
    def __init__(self, host, port, db, user, passwd, charset=‘utf8‘):
        self.host = host
        self.port = port
        self.db = db
        self.user = user
        self.passwd = passwd
        self.charset = charset

    def connect(self):
        # 创建对象：调用connect()方法
        self.conn = MySQLdb.connect(host=self.host, port=self.port, db=self.db, user=self.user, passwd=self.passwd,
                                    charset=self.charset)
        self.cursor = self.conn.cursor()

    def close(self):
        self.cursor.close()
        self.conn.close()

    # fetchone() ：
    # 返回单个的元组，也就是一条记录(row)，如果没有结果
    # 则返回
    # None
    # fetchall() ：
    # 返回多个元组，即返回多个记录(rows), 如果没有结果
    # 则返回()
    # 需要注明：在MySQL中是NULL，而在Python中则是None
    def get_one(self, sql, params=()):
        result = None
        try:
            self.connect()
            self.cursor.execute(sql, params)
            result = self.cursor.fetchone()
            self.close()
        except Exception, e:
            print e.message
        return result

    def get_all(self, sql, params=()):
        list = ()
        try:
            self.connect()
            self.cursor.execute(sql, params)
            list = self.cursor.fetchall()
            self.close()
        except Exception, e:
            print e.message
        return list

    def insert(self, sql, params=()):
        return self.__edit(sql, params)

    def update(self, sql, params=()):
        return self.__edit(sql, params)

    def delete(self, sql, params=()):
        return self.__edit(sql, params)

    def __edit(self, sql, params):
        count = 0
        try:
            self.connect()
            # 创建对象：调用Connection对象的cursor() 方法
            # 执行语句，返回受影响的行数: execute(operation[, parameters])
            count = self.cursor.execute(sql, params)
            self.conn.commit()
            self.close()
        except Exception as e:
            print e
        return count

mysql封装类

# encoding=utf-8
from MysqlHelper import MysqlHelper
from hashlib import sha1


def main():
    sqlhelper = MysqlHelper(‘127.0.0.1‘, 3306, ‘student‘, ‘root‘, ‘root‘)

    # 用户登录
    sname = raw_input("请输入用户名：")
    spwd = raw_input("请输入密码:")

    # - update(arg):根据参数来更新hash对象，
    # 多个update调用相当于把所有参数连接起来的单个update调用
    # - digest():返回hash字符串
    # - hexdigest():返回hash字符串，16进制
    # - copy():返回一个clone对象
    s1 = sha1()
    s1.update(spwd)
    spwdSha1 = s1.hexdigest()

    sql = "select upwd from users where uname=%s"
    params = [sname]
    userinfo = sqlhelper.get_one(sql, params)
    if userinfo == None:
        print ‘用户名错误‘
    elif userinfo[0] == spwdSha1:
        print ‘登录成功‘
    else:
        print ‘密码错误‘

if __name__ == ‘__main__‘:
    main()

登录