Python浅谈-Python操作数据库之MySQL(1)

python浅谈-python操作数据库之mysql(1)

一、sql：

　　关系型数据库，是指采用了关系模型来组织数据的数据库，其以行和列的形式存储数据，以便于用户理解，关系型数据库这一系列的行和列被称为表，一组表组成了数据库。用户通过查询来检索数据库中的数据，而查询是一个用于限

定数据库中某些区域的执行代码。关系模型可以简单理解为二维表格模型，而一个关系型数据库就是由二维表及其之间的关系组成的一个数据组织；

　　常见的关系型数据库有：oracle、db2、microsoft sql server、microsoft access、mysql等。

 

二、mysql简介：

　　mysql是一个关系型数据库管理系统，由瑞典mysqlab公司开发，属于oracle旗下产品。mysql 是最流行的关系型数据库管理系统之一，在 web 应用方面，mysql是最好的 rdbms(relational database management system，

关系数据库管理系统) 应用软件之一；

　　mysql所使用的 sql(structured query language,是1974年由boyce和chamberlin提出的一种介于关系代数与关系演算之间的结构化查询语言，是一个通用的、功能极强的关系性数据库语言。) 语言是用于访问数据库的最常用标准

化语言。mysql 软件采用了双授权政策，分为社区版和商业版，由于其体积小、速度快、总体拥有成本低，尤其是开放源码这一特点，一般中小型网站的开发都选择 mysql 作为网站数据库；

 

三、mysql的安装与使用：

　　可以使用的版本有mysql社区版本和mariadb两个版本，mysql下载的地址为 ，mariadb下载的地址为  ，选择合适的版本下载安装即可；

　　关于mariadb与mysql的关系可以参考 https://baike.baidu.com/item/mariadb/6466119?fr=aladdin；

 

四、mysql运行的原理：　　

　　1.存储引擎？

　　对表中数据的读取和写入的程序，默认为innodb（其他myisam、memory），将表中的数据存储到磁盘；

 　   以页作为磁盘和内存之间交互的基本单位，innodb中页的大小一般为16kb；

　　一次最少把内存中的16kb内容刷新到磁盘中，每一行都有固定的格式；

 

 

 

 图 1 数据引擎所处的位置

　　2.事务的概念：

　　<1>.什么是事务：

　　　　操作数据库从读取到写入的整个流程，一组原子性的sql查询， 或者说一个独立的工作单元。

　　<2>.事务的特性：

　　　　原子性 atomic

　　　　一致性 consistency

　　　　隔离性 isolation

　　　　持久性 durable

 

五、使用python操作mysql数据库——sqlaichemy：　　

　　1.sqlaichemy?

　　python sql工具包和对象关系映射器;

　　sqlalchemy是python sql工具包和对象关系映射器，它为应用程序开发人员 提供了sql的全部功能和灵活性 ;

　　它提供了一套众所周知的企业级持久性模式， 专为高效和高性能的数据库访问而设计 ，适用于简单且python化的领域语言;

　　作者：mike bayer     博客：

 

　　2.sqlaichemy的使用思路(主要函数介绍)：

　　declarative_base() ->创建基类

　　class -> 数据类 ->table

　　create_engine -> 数据库引擎连接数据库

　　session  -> 创建会话，类似事务

　　object -> 创建数据对

　　query -> 各种查询操作

 

　　3.python操作：

　　下面是一个以主机和管理员多对多关系的一个简单的案例：

 

　　pip install sqlaichemy   # 安装库

　　

#!/usr/bin/env python
# -*- coding:utf-8 -*-
# author:catt1e



from sqlalchemy import create_engine, column ,integer ,string, foreignkey
from sqlalchemy.orm import sessionmaker, relationship
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import and_
from sqlalchemy import or_

base = declarative_base()

class admin(base):
    '''定义admin表以及表的字段名'''
    __tablename__= 'admin'

    id = column('id', integer, primary_key=true)
    name = column('name', string(50), unique=true)

    hosts = relationship(
        'host', 
        secondary='admin_host'
    )


    def __repr__(self):
        return self.name


class host(base):
    '''定义host表以及表的字段名'''
    __tablename__= 'host'

    id = column('id', integer, primary_key=true)
    name = column('name', string(50), unique=true, nullable=false)

    admins = relationship(
        'admin', 
        secondary='admin_host'
    )


    def __repr__(self):
        return self.name

class adminhost(base):
    '''定义adminhost表以及表的字段名'''
    __tablename__ = 'admin_host'
    admin_id = column(integer, foreignkey('admin.id'), primary_key=true)
    host_id = column(integer, foreignkey('host.id'), primary_key=true)


# engine = create_engine('mysql+pymysql://username:password@localhost/db')
engine = create_engine('mysql+pymysql://root:pwdfordb826@localhost/catt1e?charset=utf8') # 引擎
base.metadata.create_all(bind=engine) # 创建数据库，注意第一次创建完成后要注释，否则进行数据库操作会报错


# session
dbsession = sessionmaker(bind=engine) # 类
session = dbsession() # 实例

def add_admin(session, id, name):
    '''添加管理员'''
    s = admin()
    s.id = id
    s.name = name
    session.add(s)
    return s

def main():
    # 增加数据
    # admin = add_admin(session, 4, 'admin_catt1e')
    # h1 = host(id=1100, name='webweb.server')
    # h2 = host(id=2200, name='dbdb.server')
    # h3 = host(id=3300, name='devdev.server')
    # admin.hosts.append(h1)
    # admin.hosts.append(h2)
    # admin.hosts.append(h3)
    # session.add(admin)
    # session.commit()

    # 查询数据
    print('all: ', session.query(admin).all())
    print('admin catt1e: ', session.query(admin).filter(admin.name.endswith('catt1e')).one())
    print('admin catt1e hosts: ', session.query(admin).filter(admin.name.endswith('catt1e')).one().hosts)
    print('dbdb.server的管理员是谁，从用户表里开始查: ', session.query(admin).filter(admin.hosts.any(host.name=='dbdb.server')).all())
    

if __name__ == '__main__':
    main()