Python和MySQL数据库简单操作

数据库分类

  1. SQL(关系型数据库)
    • MySQL
    • Oracle
    • SQL Server
    • DB2
  2. NoSQL
    这个NoSQL表示是Not Only SQL,而不是No SQL。SQL的本质是保证事物的完整性(高并发的情况下)遵循ACID?,无法水平扩展。因而NoSQL基于CAP,在牺牲事物(有可能丢失)的情况下实行水平扩展,
    • MongoDB
    • Neo4j
    • HBase

MySQL的简单操作

  1. 使用Navicat来创建表
  2. 使用Python来操作SQL
    • 首先使用开发包,主要有三种mysql-connectorMySQLdbSQLAlchemy。其中相比mysql-connectorMySQLdb用的比较多。而第一个则是官方给出的方案。
    • 安装方案如下:
      pip3 install mysql-connector    #安装mysql-connector
      pip3 install PyMySQL            #安装MySQLdb 3.x以上的替代方案

mysql-connector实操

  1. 创建链接
    from mysql import connector
    conn = connector.connect(host = 'localhost', port = 3306 ,
                            user = 'root', password = 'laoduan2008',
                            charset = 'utf8')
    conn.autocommit = True #为了不重复输入commit
    ERROR Record:
    • mysql.connector.errors.NotSupportedError: Authentication plugin 'caching_sha2_password' is not supported
      MySQL8在这里和低版本不兼容,你可以重新安装MySQL(或者用Reconfigure选项),把认证的选项设置为“Use Legacy Authentication Method”, 或者你如果不是必须要用MySQL 8,可以降级到低版本。
  2. 创建游标
    cursor = conn.cursor()
    sqltext = 'insert into users(name, address, email) values ("deamov","beijing","abc@blabla")'
    #设置语句
    
    text_temple = 'insert into users(name, address, email) values (%s ,%s ,%s)'
    cursor.executemany(sql_template,userinfo)
    #如何执行多条语句
  3. 执行SQL
    cursor.execute(sqltext)
    #执行语句
  4. 关闭连接
    cursor.close()
    conn.close()

PyMySQL

  1. 创建链接
    import pymysql
    conn = pymysql.connect()
    
    conn.autocommit(True)
    ERROR Record
    • pymysql.err.OperationalError: (1045, "Access denied for user 'root'@'localhost' (using password: NO)")
      有可能是root账号的密码这些不能登陆,通过root账号登陆后,分配一个账号类似CREATE USER 'deamov'@'localhost IDENTIFIED WITH mysql_native_password BY 'password';。之后,use your_database_name选择了你要用的数据库后,将权限给你的新的账户grant all privileges on *.* to deamov@localhost
  2. 创建游标
    cursor = conn.cursor()
    #mysql-connector用的是弱引用
    #PyMySQL的游标可以在函数里用
  3. 执行SQL
    sqltext = 'select * from users'
    
    cursor.excute(sqltext)
    for row in cursor:
        print row
    #读取所有的
    for row in cursor.fetchmany(2):
        print row
    #读取两条
    from faker import Factory
    userfaker = Factory.create()
    userinfo = [(userfaker.name(),userfaker.address(),userfaker.email()) for i in range(10)]
    
    text_temple = 'insert into users(name, address, email) values (%s ,%s ,%s)
    cursor.executemany(sql_template,userinfo)
    #批量插入
  4. 关闭链接
    cursor.close()
    conn.close()

SQLAlchemy

The Python SQL Toolkit and Object Relational Mapper。
ORM(O是面向对象,R是面向关系,M是Map):
面向对象和面向关系的模拟关联。

  • 表映射到类
    • 行映射到对象
    • 列映射到属性

优点如下

  1. 隐藏数据库实现
  2. 良好的数据库操作接口,简单,学习成本低。
  3. 动态数据表映射

开发步骤

  1. 创建链接

相关推荐