文章目录
 数据库简介E-R模型:范式
  MySQL(mariadb)简介与安装简介安装安全性密码设置本地登陆允许远程连接找回密码
  数据库操作数据库操作表操作表创建数据完整性字段类型约束
   
   数据操作备份与恢复
  查询操作查询的基本语法消除重复行条件分组分组后的数据筛选
   聚合排序获取部分行总结
  pymysql数据库编程项目案例: 银行转账系统测试
 
 
数据库简介
 
人类在进化的过程中,创造了数字、文字、符号等来进行数据的记录,但是承受着认知能力和创造能力的提 升,数据量越来越大,对于数据的记录和准确查找,成为了一个重大难题.
 
计算机诞生后,数据开始在计算机中存储并计算,并设计出了数据库系统
 
数据库系统解决的问题:持久化存储,优化读写,保证数据的有效性
 
当前使用的数据库,主要分为两类: 文档型,如sqlite,就是一个文件,通过对文件的复制完成数据库的复制 服务型,如mysql、postgre,数据存储在一个物理文件中,但是需要使用终端以tcp/ip协议连接,进行数 据库的读写操作
 
E-R模型:
 
当前物理的数据库都是按照E-R模型进行设计的,
 
E表示entry,实体R表示relationship,关系 
一个实体转换为数据库中的一个表
 
关系描述两个实体之间的对应规则,包括: 一对一 ,一对多, 多对多 
 
范式
 
经过研究和对使用中问题的总结,对于设计数据库提出了一些规范,这些规范被称为范式
 
第一范式(1NF):列不可拆分第二范式(2NF):唯一标识第三范式(3NF):引用主键 
说明:后一个范式,都是在前一个范式的基础上建立的
 
MySQL(mariadb)简介与安装
 
简介
 
MySQL是一个关系型数据库管理系统,由瑞典MySQL AB 公司开发,目前属于 Oracle 旗下产品。MySQL 是最流行的关系型数据库管理系统之一。
 
安装
 
 
 
安全性密码设置
 
终端输入**mysql_secure_installation **命令 
 
本地登陆
 
mysql -uroot -p[密码]
或
mysql -uroot -p
输入密码
 
允许远程连接
 
1.关闭mysql服务器的防火墙  2.用户授权: 允许root用户通过westos密码 在任意主机(%)远程登陆并操作数据库;
 
本地登陆mysql后,输入
 
grant all privileges on *.* to root@'ip' identified by '密码'
# ip为%表式任意ip 
 
 3.客户端主机测试(安装mariadb软件)
 
mysql -h<mysql服务器ip> -uroot -p
 
 
找回密码
 
用户信息存储在mysql数据库的user表中
 
跳过授权表进入数据库,修改user表中Password数据即可重新设置密码 
 
数据库操作
 
数据库操作
 
 
表操作
 
 
表创建
 
数据完整性
 
一个数据库就是一个完整的业务单元,可以包含多张表,数据被存储在表中
 
在表中为了更加准确的存储数据,保证数据的正确有效,可以在创建表的时候,为表添加一些强制性的验证, 包括数据字段的类型、约束
 
字段类型
 
在mysql中包含的数据类型很多,这里主要列出来常用的几种:
 
数字:int,decimal, float字符串:varchar,text日期:datetime布尔:bool 
约束
 
主键 primary key 非空 not null 惟一 unique 默认 default 外键 foreign key 自动增长 auto_increment
 
数据操作
 
 
备份与恢复
 
 
查询操作
 
查询的基本语法
 
select * from 表名;
 
from关键字后面写表名,表示数据来源于是这张表 select后面写表中的列名,如果是*表示在结果中显示表中所有列 在select后面的列名部分,可以使用as为列起别名,这个别名出现在结果集中 如果要查询多个列,之间使用逗号分隔
 
消除重复行
 
在select后面列前使用distinct可以消除重复的行
 
select distinct gender from students;
 
条件
 
使用where子句对表中的数据筛选,结果为true的行会出现在结果集中
 
select * from 表名 where 条件;
 
优先级: 小括号,not,比较运算符,逻辑运算符 and比or先运算,如果同时出现并希望先算or,需要结合()使用 
 
分组
 
按照字段分组,表示此字段相同的数据会被放到一个组中 分组后,只能查询出相同的数据列,对于有差异的数据列无法出现在结果集中 可以对分组后的数据进行统计,做聚合运算
 
select 列1,列2,聚合... from 表名 group by 列1,列2,列3...
 
 
 
分组后的数据筛选
 
having后面的条件运算符与where的相同   对比: where是对from后面指定的表进行数据筛选,属于对原始数据的筛选 having是对group by的结果进行筛选
 
聚合
 
为了快速得到统计数据,提供了5个聚合函数: 
 
排序
 
为了方便查看数据,可以对数据进行排序: 
 
将行数据按照列1进行排序,如果某些行列1的值相同时,则按照列2排序,以此类推默认按照列值从小到大排列asc从小到大排列,即升序, desc从大到小排序,即降序 
获取部分行
 
当数据量过大时,在一页中查看数据是一件非常麻烦的事情: 
 
从start开始,获取count条数据start索引从0开始 
总结
 
完整的select语句  注意: 实际使用中,只是语句中某些部分的组合,而不是全部
 
执行顺序为: 1. from 表名 2. where … 3. group by … 4. select distinct * 5. having … 6. order by … 7. limit star,count
 
pymysql数据库编程
 
PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库,Python2中则使用MySQLdb。   
 
项目案例: 银行转账系统测试
 
"""
Date:2019-07-19 11:51
User:LiYu
Email:liyu_5498@163.com
"""
import pymysql
class TransferMoney(object):
    def __init__(self
, conn
):
        self
.conn 
= conn
        self
.cur 
= conn
.cursor
()
    def transfer(self
, source_id
, target_id
, money
):
        if not self
.check_account_avaialbe
(source_id
):
            raise Exception
('账户不存在')
        if not self
.check_account_avaialbe
(target_id
):
            raise Exception
('账户不存在')
        if self
.has_enough_money
(source_id
, money
):
            try:
                self
.reduce_money
(source_id
, money
)
                self
.add_money
(target_id
, money
)
            except Exception 
as e
:
                print('转账失败', e
)
                self
.conn
.rollback
()
            else:
                self
.conn
.commit
()
                print('%s给%s转账%s元成功' % (source_id
, target_id
, money
))
        else:
            print('没有足够的金额')
    def check_account_avaialbe(self
, acc_id
):
        select_sqli 
= 'select * from bank where id=%s;' % acc_id
        
print('execute sql:', select_sqli
)
        res_count 
= self
.cur
.execute
(select_sqli
)
        if res_count 
== 1:
            return True
        else:
            return False
    def has_enough_money(self
, acc_id
, money
):
        select_sqli 
= 'select money from bank where id=%s;' % acc_id
        
print('execute sql:', select_sqli
)
        self
.cur
.execute
(select_sqli
)  
        acc_money 
= self
.cur
.fetchone
()[0]
        if acc_money 
>= money
:
            return True
        else:
            return False
    def reduce_money(self
, acc_id
, money
):
        update_sqli 
= 'update bank set money=money-%d where id=%s' % (money
, acc_id
)
        print('reduce money:', update_sqli
)
        self
.cur
.execute
(update_sqli
)
    def add_money(self
, acc_id
, money
):
        update_sqli 
= 'update bank set money=money+%d where id=%s' % (money
, acc_id
)
        print('add money:', update_sqli
)
        raise Exception
('111')
        self
.cur
.execute
(update_sqli
)
    def __del__(self
):
        self
.cur
.close
()
        self
.conn
.close
()
if __name__ 
== '__main__':
    conn 
= pymysql
.connect
(
        host
='172.25.254.128',
        user
='root',
        password
='westos',
        db
='pymysql',
        charset
='utf8',
        autocommit
=True  
    )
    T 
= TransferMoney
(conn
)
    
    
    T
.transfer
('130001', '130002', 200)