python学习之pymysql和sqlalchemy

PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库,
Python2中则使用MySQLdb。


数据库查询操作

创新互联建站成立十年来，这条路我们正越走越好，积累了技术与客户资源，形成了良好的口碑。为客户提供成都做网站、网站建设、外贸营销网站建设、网站策划、网页设计、主机域名、网络营销、VI设计、网站改版、漏洞修补等服务。网站是否美观、功能强大、用户体验好、性价比高、打开快等等，这些对于网站建设都非常重要，创新互联建站通过对建站技术性的掌握、对创意设计的研究为客户提供一站式互联网解决方案，携手广大客户，共同发展进步。

01_python数据库编程基本操作.py

import pymysql

#1). 创建数据库连接, autocommit是否自动提交修改到数据库中.
conn = pymysql.connect(host='localhost', user='root', password='westos',
                db='Blog', port=3306, autocommit=True, charset='utf8')
#2). 创建游标(用来执行sql语句的)
cur = conn.cursor()

#3). 执行sql语句
insert_sql = 'insert into users(username) values ("user6");'
cur.execute(insert_sql)

print("插入数据成功.......")
#4). 关闭游标
cur.close()
#5）.关闭连接
conn.close()

02_python数据库编程基本操作.py

class Connection(object):
  def __enter__(self):
        Context manager that returns a Cursor
        warnings.warn(
            "Context manager API of Connection object is deprecated; Use conn.begin()",
            DeprecationWarning)
        return self.cursor()

    def __exit__(self, exc, value, traceback):
        On successful exit, commit. On exception, rollback(回滚)
        if exc:
            self.rollback()
        else:
            self.commit()
import pymysql

#使用with语句是， pymysql.connect返回的是数据库游标。(具体的内容查看源代码)
with pymysql.connect(host='localhost', user='root', password='westos',
                db='Blog', port=3306, autocommit=True, charset='utf8') as cur:
    #3). 执行sql语句(增删改)
    insert_sql = 'insert into users(username) values ("user7");'
    cur.execute(insert_sql)
    print("插入数据成功.......")

03_数据库批量操作.py

import pymysql

users = [('redhat' + str(i), 'passwd'+str(i)) for i in range(100)]
#users = [('redhat1', 'passwd1'), ('redhat2', 'passwd2'), .......]

#使用with语句是， pymysql.connect返回的是数据库游标。(具体的内容查看源代码)
with pymysql.connect(host='localhost', user='root', password='westos',
                db='Blog', port=3306, autocommit=True, charset='utf8') as cur:
    #3). 执行sql语句(增删改)
    insert_sql = 'insert into users(username, password) values (%s, %s);'
    #execute: 执行一条sql语句。
    #executemany: 执行多条sql语句。
    #'insert into users(username, password) values (%s, %s);' %users[0]
    #'insert into users(username, password) values (%s, %s);' %('redhat1', 'passwd1')
    #'insert into users(username, password) values (%s, %s);' %users[1]
    #'insert into users(username, password) values (%s, %s);' %users[2]
    cur.executemany(insert_sql, users)
    print("插入数据成功.......")

04_python查询数据库信息.py

import pymysql

with pymysql.connect(host='localhost', user='root', password='westos',
                db='Blog', port=3306, autocommit=True, charset='utf8') as cur:
    #3). 执行sql语句(增删改)
    query_sql = 'select * from users where username like "user%";'
    #Number of affected rows
    result = cur.execute(query_sql)
    print("符合条件的记录数: ", result)

    #print(cur.fetchone())
    #print(cur.fetchmany(2))
    users_info = cur.fetchall()

#以表格方式美观的打印。
from  prettytable import  PrettyTable
pt = PrettyTable(field_names=['编号', '用户名', '密码'])
for user in users_info:
    pt.add_row(user)
print(pt)

05_sqlite数据库.py

1. 什么是sqlite数据库?
SQLite是内嵌在Python中的轻量级、基于磁盘文件袋额数据库管理系统(就是一个文件)，
不需要安装和配置服务，支持使用SQL语句来访问数据库。该数据库使用C语言开发，支持大多数SQL91标准，
支持原子的、一致的、独立的和持久的事务，不支持外键限制；通过数据库级的独占性和共享性锁定来实现独立事务，
当多个线程同时访问同一个数据库并试图写入数据时，每一时刻只有一个线程可以写入数据。
2. sqlite数据库的特性:
　　SQLite支持最大140TB大小的单个数据库，每个数据库完全存储在单个磁盘文件中，
以B+树数据结构的形式存储，一个数据库就是一个文件，通过直接复制数据库文件就可以实现数据库的备份。
如果需要使用可视化管理工具，可以下载并使用SQLiteManager、SQLite Database Browser 或其他类似工具。
import sqlite3
#1). 创建连接
conn = sqlite3.connect(database='users.sqlite')

#2). 创建游标
cur = conn.cursor()

#3). 操作
#if not exists如果数据库标不存在时创建表，否则不做操作。
create_sql = 'create table if not exists userinfo1 (id int auto_increment primary key , name varchar(10) unique, passwd varchar(10) default "123");'
cur.execute(create_sql)
insert_sql = 'insert into userinfo1(name) values("user2");'
cur.execute(insert_sql)
#数据操作(增删改)一定需要提交。
conn.commit()
select_sql = 'select * from userinfo1'
cur.execute(select_sql)
print("查询结果: ", cur.fetchall())

cur.close()
conn.close()

什么是ORM?
ORM,即Object-Relational Mapping(对象关系映射),它的作用是在关系型数据库和
业务实体对象之间作一个映射,这样,我们在具体的操作业务对象的时候,就不需要再
去和复杂的SQL语句打交道,只需简单的操作对象的属性和方法。

安装sqlalchemy

1. 需要一台有安装mysql数据库的机器
2. 安装模块: pip3 install sqlalchemy
3. 查看版本信息
   连接数据库
   在sqlalchemy中,session用于创建程序与数据库之间的会话。所有对象的载
   入和保存都需要通过session对象。
   
   创建映射(创建表)
   一个映射对应着一个Python类,用来表示一个表的结构。
   
   添加单条数据
   
   添加多条数据
   
   查找数据
   在sqlalchemy模块中,查找数据给提供了query()的方法
   
   删除数据
   

06_对象关系映射.py

import sqlalchemy
from sqlalchemy import Column, Integer, String
from sqlalchemy.ext.declarative import declarative_base
import pymysql
pymysql.install_as_MySQLdb()

#object(oop) ---> mysql(SQL)
#1). 创建数据库引擎(连接数据库的过程)
#echo=True显示翻译好的SQL语句。
from sqlalchemy.orm import Session, sessionmaker

engine = sqlalchemy.create_engine("mysql://root:westos@localhost/Blog",
                         encoding='utf8', echo=True)

#2). 建立缓存
session = sessionmaker(bind=engine)()

#3). 创建数据库对象需要继承的基类
Base = declarative_base()

#4). 创建类, 一个类就是一个数据库表
class Student(Base):
    # 数据库表的名称
    __tablename__ = 'student_info'
    #数据库表的属性信息
    id = Column(Integer, primary_key=True, autoincrement=True)
    name = Column(String(20))
    sex = Column(String(10))

    #def __repr__(self):
    #return  'Student<%s>' %(self.name)

if __name__ == '__main__':
    # 根据设置的信息创建数据库表-(创建类:创建数据库表的过程)
    Base.metadata.create_all(engine)

    #添加数据信息(实例化对象: 添加一条数据/记录)
    #INSERT INTO student_info (id, name, sex) VALUES (%(id)s, %(name)s, %(sex)s)
    stu1 = Student(id=2, name='westos2', sex='男')
    #stu2 = Student(id=3, name='westos3', sex='男')
    #stu3 = Student(id=4, name='westos4', sex='女')
    session.add_all([stu1, ])
    session.commit()

    #查询数据信息
    print(session.query(Student).all())

    #根据筛选条件查询信息
    print(session.query(Student).filter_by(name='westos1').all())
    print(session.query(Student).filter_by(name='westos1').first())
    print(session.query(Student).filter_by(name='westoshdhwhdewd').first())

    #删除数据
    stu1 = session.query(Student).filter_by(name='westos2').first()

    print("before delete: ", stu1)
    session.delete(stu1)
    session.commit()
    stu1 = session.query(Student).filter_by(name='westos1').first()
    print("after delete: ", stu1)