本文主要是介绍python学习——pymql，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

python学习——pymql

• 基础
• 步骤(以查询为例)
• • 创建、插入、更新和删除
  • • 创建
    • 插入、更新与删除

基础

• pymql是第三方库，需要安装PYMYSQL
• 使用是要导入pymysql模块

步骤(以查询为例)

• 第一步：使用connect()打开数据库，需要三个参数，分别为：host、user、password。host为数据库的ip地址；user为登录名；password为登录密码。database为选填参数，是数据库
• 第二步：cursor() 方法创建一个游标对象 cursor，不需要传参
• 第三步：execute() 方法执行 SQL 查询 ，需要传入dql语句的参数
• 第四步：使用 fetchone() 方法获取单条数据，可打印；用fetchmany()可获取多条数据，需要传入条数参数；用fetchall()可以获取全部数据
• 第五步：关闭数据库close()
• 代码示例：

import pymysql

class DbSql:

    def __init__(self,host,user,password,database):
        self.host = host
        self.user = user
        self.password = password
        self.database = database
        #链接数据库
        self.db = pymysql.connect(host=host,user=user,
                     password=password,database=database)

    def do_mysql(self,sql):
        # 使用 cursor() 方法创建一个游标对象 cursor
        cursor = self.db.cursor()
        # 使用 execute()  方法执行 SQL 查询
        cursor.execute(sql)
        # 使用 fetchone() 方法获取单条数据.
        data_one = cursor.fetchone()#获取一条数据
        data_money = cursor.fetchmany(5)#获取多条数据，需要传入条数参数
        data_all = cursor.fetchall()#获取全部数据
        #打印数据
        print("一条结果：",data_one)
        print("==================分割线==================")
        print("多条结果：",data_money)
        print("==================分割线==================")
        print("全部结果：",data_all)

        #关闭数据库
        self.db.close()

创建、插入、更新和删除

创建

• 创建的步骤和查询差不多，只是将sql语句变为创建数据库的sql即可
• • 第一步：使用connect()打开数据库，需要三个参数，分别为：host、user、password。host为数据库的ip地址；user为登录名；password为登录密码。database为选填参数，是数据库
• 第二步：cursor() 方法创建一个游标对象 cursor，不需要传参
• 第三步：execute() 方法执行 SQL 查询 ，创建喊出数据库的语句，可使用if判断，如果数据库存在就删除
• 第四步：execute() 方法执行 SQL 查询 ，传入创建数据库的sql语句
• 第五步：关闭数据库close()
• 代码示例：

import pymysql

class DbSql:

    def __init__(self,host,user,password,database):
        self.host = host
        self.user = user
        self.password = password
        self.database = database
        #链接数据库
        self.db = pymysql.connect(host=host,user=user,
                     password=password,database=database)

    def do_mysql(self,sql):
        # 使用 cursor() 方法创建一个游标对象 cursor
        cursor = self.db.cursor()
        # 使用 execute() 方法执行 SQL，如果表存在则删除
        cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")
        # 使用 execute()  方法执行 SQL 查询
        cursor.execute(sql)#sql为创建数据库的sql

        #关闭数据库
        self.db.close()

插入、更新与删除

• • 第一步：使用connect()打开数据库，需要三个参数，分别为：host、user、password。host为数据库的ip地址；user为登录名；password为登录密码。database为选填参数，是数据库
• 第二步：cursor() 方法创建一个游标对象 cursor，不需要传参
• 第三步：execute() 方法执行 SQL 查询 ，sql语句其插入数据、更新数据或者删除数据的sql
• 第四步：commit()方法，提交sql到数据库去执行，需要用到异常处理，如果发生问题就回滚（rollback()）
• 第五步：关闭数据库close()
• 代码示例：

import pymysql

class DbSql:

    def __init__(self,host,user,password,database):
        self.host = host
        self.user = user
        self.password = password
        self.database = database
        #链接数据库
        self.db = pymysql.connect(host=host,user=user,
                     password=password,database=database)

    def do_mysql(self,sql):
        # 使用 cursor() 方法创建一个游标对象 cursor
        cursor = self.db.cursor()
        try:
            # 执行sql语句
            cursor.execute(sql)#sql为插入数据、更新数据或者删除数据的语句
            # 提交到数据库执行
            self.db.commit()
        except:
            # 如果发生错误则回滚
            self.db.rollback()

        #关闭数据库
        self.db.close()

这篇关于python学习——pymql的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！