Python 连接 MySQL 数据库_pymysql

• 简介

  用于连接mysql服务器的一个库，PyMySQL 遵循Python 数据库 API v2.0规范，并包含了 pure-Python MySQL 客户端库。

• 安装 PyMSQL

  pip3 install PyMySQL
  

• 数据库连接

  **注意：**连接数据库前，要确保已经创建数据以及数据表。

  • 实例

    
    """
    插入数据
    """
    import pymysql
    
    #打开数据库连接
    conn = pymysql.connect(host='localhost',
                           port=3306,
                           user ='root',
                           password='ZL123123',
                           database='test01')
    
    #创建一个游标对象
    cursor =conn.cursor()
    
    #数据表插入数据
    sql = "insert into test02(id,bookName) values(1,'菜鸟教程')"
    
    try:
        #执行sql语句
        cursor.execute(sql)
        #提交到数据库执行
        conn.commit()
    except Exception as e:
        #如果发生错误则回滚
        conn.rollback()
        print("Error:",e)
    
    #关闭数据库
    conn.close()
    

    """
    查询数据
    
    数据库查询操作
    1.fetchone()：该方法获取下一个查询结果集，结果集是一个对象。
    2.fetchall()：接受全部的返回结果行。
    3.rowcount()：这是一个只读属性，并返回执行execute()方法后影响的行数
    """
    import pymysql
    
    #打开数据库连接
    conn = pymysql.connect(host='localhost',
                           port=3306,
                           user ='root',
                           password='ZL123123',
                           database='test01')
    
    #创建一个游标对象
    cursor =conn.cursor()
    
    #数据表插入数据
    sql = "select id,bookName from test02"
    #执行sql语句
    cursor.execute(sql)
    
    # 获取单条数据
    data = cursor.fetchone()
    
    print("数据如下：",data)
    #关闭数据库
    conn.close()
    

• 创建数据库表

  可以用execute()方法创建数据库表

  import pymysql
  
  #打开数据库连接
  conn = pymysql.connect(host='localhost',
                         port=3306,
                         user ='root',
                         password='ZL123123',
                         database='test01')
  
  #创建一个游标对象
  cursor =conn.cursor()
  
  #如果表test03存在，则删除
  cursor.execute("drop table if exists test03")
  
  #创建数据库表
  sql = """create table test03(id int primary key,price double,type varchar(50))"""
  
  # 执行sql语句
  cursor.execute(sql)
  #关闭数据库
  conn.close()
  

• 执行事务

  事务机制可以确保数据一致性。

  事务应该具有4个属性：

  • 原子性
  • 一致性
  • 隔离性
  • 持久性

  Python DB API 2.0 的事务提供了两个方法commit或rollback。