创建表book
create table t_book(
id int unsigned auto_increment primary key,
bookName varchar(255) default null,
price decimal(6,2) default null,
author varchar(255) default null,
bookTypeId int(11) default null
);
insert into t_book values(1, '追风筝的人', '29.00', '胡赛尼', 1);
insert into t_book values(2, '计算机', '45.00', 'Harold', 2);
insert into t_book values(3, '代码大全', '128.00', '史蒂夫', 2);
insert into t_book values(4, '哥德尔 ', '88.00', '侯世达', 3);
insert into t_book values(5, '呵呵', '4.50', '[中]老子', 4);
create table t_bookType(
id int(11) auto_increment not null primary key,
bookTypeName varchar(10) default null
);
insert into t_bookType values(1, '小说类');
insert into t_bookType values(2, '编程类');
insert into t_bookType values(3, '哲学类');
insert into t_bookType values(5, '艺术类');
分页查询: limit
# limit 后的参数:第一个表示 起始位置(下标从0开始),第二个参数是显示的个数(表示本次基于起始位置显示多少个)
select * from t_hero limit 0,3
# 结合where条件:只显示state不为null 的结果
select * from t_hero where state is not null limit 0,20
+----+-----------------------------------------------------+--------+----------------------------------------------------------+------------+----+--------------+
| id | bookName | price | author | bookTypeId | id | bookTypeName |
+----+-----------------------------------------------------+--------+----------------------------------------------------------+------------+----+--------------+
| 1 | 追风筝的人 | 29.00 | [美] 卡勒德·胡赛尼 | 1 | 1 | 小说类 |
| 2 | 计算机程序的构造和解释 : 原书第2版 | 45.00 | [美]Harold Abelson、Gerald Jay Sussman、Julie Sussman | 2 | 2 | 编程类 |
| 3 | 代码大全(第2版) | 128.00 | [美] 史蒂夫·迈克康奈尔 | 2 | 2 | 编程类 |
| 4 | 哥德尔、艾舍尔、巴赫 : 集异璧之大成 | 88.00 | [美] 侯世达 | 3 | 3 | 哲学类 |
| 5 | 道德经 | 4.50 | [中]老子 | 4 | 4 | 艺术类 |
+----+-----------------------------------------------------+--------+----------------------------------------------------------+------------+----+--------------+
- - - - - - - 连接查询: 表示多个表之间的关联查询
1. 内连接:INNER JOIN ON
#连接查询:表示查询所有数据的非NULL部分
#默认是内连接
SELECT *
FROM t_book, t_bookType
WHERE t_book.bookTypeId = t_bookType.id;
select * from t_book, t_bookType where t_book.bookTypeId = t_bookType.id;
# 隐式连接中
# 给每张表起别名用:as
SELECT tb.bookName, tb.price, tby.bookTypeName
FROM t_book as tb, t_bookType as tby
WHERE tb.bookTypeId = tby.id;
# 显式连接
SELECT tb.bookName, tb.price, tby.bookTypeName
FROM t_book as tb
INNER JOIN t_bookType as tby
ON tb.bookTypeId = tby.id;
交集: 属于A集合,也 属于B集合 的数据, A & B
并集: 属于A集合 和 属于B 的数据的全部集合, A | B(重复数据只保留一个)
2. 左连接 : LEFT JOIN ON
# 两张表连接查询,无论二者是否有数据缺失,一定会把左边的表数据全部显示出来
SELECT *
FROM t_book
LEFT JOIN t_bookType
ON t_book.bookTypeId = t_bookType.id
SELECT tb.bookName, tb.price, tb.author, tby.bookTypeName
FROM t_book as tb
LEFT JOIN t_bookType as tby
ON tb.bookTypeId = tby.id
3. 右连接: RIGHT JOIN ON
# 两张表连接查询,无论二者是否有数据缺失,一定会把右边的表数据全部显示出来
SELECT *
FROM t_book
RIGHT JOIN t_bookType
ON t_book.bookTypeId = t_bookType.id
SELECT tb.bookName, tb.price, tb.author, tby.bookTypeName
FROM t_book as tb
RIGHT JOIN t_bookType as tby
ON tb.bookTypeId = tby.id
4. 全连接: UNION :
# 两张表连接查询,无论二者是否有数据缺失,一定会都显示表数据全部显示出来
SELECT tb.bookName, tb.price, tb.author, tby.bookTypeName
FROM t_book as tb
LEFT JOIN t_bookType as tby
ON tb.bookTypeId = tby.id
UNION
SELECT tb.bookName, tb.price, tb.author, tby.bookTypeName
FROM t_book as tb
RIGHT JOIN t_bookType as tby
ON tb.bookTypeId = tby.id
SELECT tb.bookName,tb.author,tby.bookTypeName FROM t_book tb,t_bookType tby WHERE tb.bookTypeId=tby.id AND tb.price>30;
- - - - 子查询
1. 子查询: IN
#在 select 语句的返回值的集合里里查找,复合集合里的数据的部分,才会匹配成功。
SELECT *
FROM t_book
WHERE bookTypeId
IN (SELECT id FROM t_bookType);
2. 子查询: NOT IN:
# 和 in相反,不在集合里的数据,才会匹配成功
SELECT *
FROM t_book
WHERE bookTypeId
NOT IN (SELECT id FROM t_bookType);
3. 子查询:EXISTS 返回Bool值,如果子查询语句里查询成功,则返回True,否则返回False
SELECT *
FROM t_book
WHERE EXISTS
(SELECT * FROM t_bookType);
4. 子查询:NOT EXISTS: 对子查询语句返回的结果取反。
SELECT *
FROM t_book
WHERE NOT EXISTS
(SELECT * FROM t_bookType);
自关联 查询
文件名: areas.sql
创建数据库
mysqlcreate database china charset utf8;
切换数据库
mysqluse china;
创建表
create table areas (
aid int(11) primary key,
atitle varchar(20) default null,
pid int(11) default null
);
执行指定sql文件的数据插入
mysqlsource ./Desktop/areas.sql
查找 河北省 下面的所有城市
SELECT city.*
FROM areas as city
INNER JOIN areas as province
ON city.pid = province.aid
WHERE province.atitle='河北省' "
SELECT city.*
FROM areas as city
INNER JOIN areas as province
ON city.pid = province.aid
WHERE province.atitle='内蒙古自治区';
查找 保定市 下面的所有区县
select dis.*
FROM areas as dis # 别名1:表示区县
INNER JOIN areas as city # 别名2:表示城市
ON dis.pid=city.aid #内连接条件:区县的pid 和 城市 aid 相同
WHERE city.atitle = "保定市" # 查询结果条件:城市名为 "保定市"
select dis.*
FROM areas as dis
INNER JOIN areas as city
ON dis.pid=city.aid
WHERE city.atitle = "保定市"
事务
事务(Transaction)是并发控制的基本单位。 所谓事务,它是一个操作序列,这些操作要么都执行,要么都不执行, 它是一个不可分割的工作单位。 例如,银行转帐工作:从一个帐号扣款并使另一个帐号增款, 这两个操作要么都执行,要么都不执行。 所以,应该把他们看成一个事务。 事务是数据库维护数据一致性的单位,在每个事务结束时,都能保持数据一致性 为什么要有事务 事务广泛的运用于订单系统、银行系统等多种场景 例如: A用户和B用户是银行的储户, 现在A要给B转账500元,那么需要做以下几件事: 检查A的账户余额>500元; A账户扣除500元; B账户增加500元; 正常的流程走下来,A账户扣了500,B账户加了500,皆大欢喜。 那如果A账户扣了钱之后,系统出故障了呢? A白白损失了500,而B也没有收到本该属于他的500。 以上的案例中,隐藏着一个前提条件: A扣钱和B加钱,要么同时成功,要么同时失败。 事务的需求就在于此 事务四大特性(简称ACID) 原子性(Atomicity): 事务中的全部操作在数据库中是不可分割的,要么全部完成,要么均不执行 一致性(Consistency): 几个并行执行的事务,其执行结果必须与按某一顺序串行执行的结果相一致 隔离性(Isolation): 事务的执行不受其他事务的干扰,事务执行的中间结果对其他事务必须是透明的 持久性(Durability): 对于任意已提交事务,系统必须保证该事务对数据库的改变不被丢失,即使数据库出现故障 事务命令 要求:表的引擎类型必须是innodb类型才可以使用事务,这是mysql中表的默认引擎 查看表的创建语句,可以看到engine=innodb show create table students; 开启事务: 执行insert、update、delete语句时,变更会维护到本地缓存中,而不维护到物理表中 begin; 提交事务:将缓存中的数据变更维护到物理表中 commit; 回滚事务:放弃缓存中变更的数据 rollback; 示例1:提交 步骤1:打开两个终端,连接mysql,使用同一个数据库,操作同一张表 终端1 select * from students; 终端2:开启事务,插入数据 begin; insert into students(sname) values('张飞'); 步骤2 终端1:查询数据,发现并没有新增的数据 select * from students; 步骤3 终端2:完成提交 commit; 终端1:查询,发现有新增的数据 select * from students; 示例2:回滚 步骤1:打开两个终端,连接mysql,使用同一个数据库,操作同一张表 终端1 select * from students; 终端2 begin; insert into students(sname) values('张飞'); 步骤2 终端1:查询数据,发现并没有新增的数据 select * from students; 步骤3 终端2:完成回滚 rollback; 终端1:查询数据,发现没有新增的数据 select * from students;
mysql与Python交互
# coding=utf-8 import MySQLdb def insert_data(): # 指定一个SQL语句 # 插入数据 #sql = "INSERT INTO t_book(bookName, price, author, bookTypeId) VALUES ('三体1', 55.60, '[中]刘慈欣', 8)" # 更新数据 #sql = "UPDATE t_book set price = 100.00 where bookTypeId=8" # 删除数据 sql = "DELETE FROM t_book where bookName like '%三体%'" try: # 创建MySQL数据库连接对象 conn = MySQLdb.connect( host = "localhost", # 指定数据库所在的ip port = 3306, # 指定数据库的端口号 user = 'root', # 指定登录数据库的用户 passwd = 'mysql', # 登录数据库的用户密码 db = 'db_book', # 指定的操作的数据库名称 charset = 'utf8' # 指定字符集,和数据库字符集相同 ) # 创建数据库操作游标,可以用来执行SQL语句 cursor = conn.cursor() # 使用游标执行SQL语句 cursor.execute(sql) # 因为在MySQL和Python交互,都是事务,所以要用commit()提交事务 conn.commit() except Exception, e: print e # 如果出错,则回滚之前的操作 conn.rollback() finally: # 先关闭游标 cursor.close() # 再关闭数据库连接 conn.close() print "LOG: 执行结束!" if __name__ == "__main__": insert_data() fetchall()执行查询时,获取结果集的所有行,一行构成一个元组,再将这些元组装入一个元组返回 fetchone()执行查询语句时,获取查询结果集的第一个行数据,返回一个元组 reCount=cur.execute('select * from admin')#返回本次操作影响的记录数 print reCount data=cur.fetchall()#获得 'select * from admin'语句 返回的结果集 print data cur.scroll(0,mode='absolute')#光标回到初始位置0处(绝对定位) print cur.fetchone()#此时,光标位置为0;返回位置为0的记录 print cur.fetchone()#返回位置为1的记录 cur.scroll(1,mode='absolute')#光标回到1处(绝对定位) print cur.fetchone()#返回位置为1的记录 cur.scroll(-2,mode='relative')#光标回退2步(相对定位) print cur.fetchmany(3)#从光标所在的位置(此时,光标位于0处),连续读取3条记录 cur.scroll(1,mode='relative')#光标前进1步(相对定位) print cur.fetchone()#返回光标(位于4处)指向的那一条记录 # coding=utf-8 import MySQLdb def main(): sql = "select * from t_hero;" try: conn = MySQLdb.connect( host = "localhost", port = 3306, user = 'root', passwd = 'mysql', db = 'db_sanguo', charset = 'utf8' ) cursor = conn.cursor() cursor.execute(sql) data = cursor.fetchall() for i in data: if list(i)[0] == 6: print list(i)[0],list(i)[1] # cursor.scroll(6,mode='absolute') # cursor.scroll(2,mode='relative') # wer = cursor.fetchone() # print list(wer)[0],list(wer)[1],list(wer)[2],list(wer)[3] # cursor.scroll(-2,mode='relative') # print cursor.fetchmany(3) # cur.scroll(1,mode='relative') conn.commit() except Exception, e: print e # 如果出错,则回滚之前的操作 conn.rollback() finally: # 先关闭游标 cursor.close() # 再关闭数据库连接 conn.close() print "LOG: 执行结束!" if __name__ == "__main__": main()
传参的方式
# coding=utf-8 import MySQLdb def insert_data(): try: # 创建MySQL数据库连接对象 conn = MySQLdb.connect( host = "localhost", # 指定数据库所在的ip port = 3306, # 指定数据库的端口号 user = 'root', # 指定登录数据库的用户 passwd = 'mysql', # 登录数据库的用户密码 db = 'db_sanguo', # 指定的操作的数据库名称 charset = 'utf8' # 指定字符集,和数据库字符集相同 ) name = raw_input("请输入英雄的大名:") age = raw_input("请输入英雄的年龄:") wer = [name,age] # 创建数据库操作游标,可以用来执行SQL语句 cursor = conn.cursor() # 使用游标执行SQL语句 qw = cursor.execute("insert into t_hero(name,age) values(%s,%s)",wer) print qw # 因为在MySQL和Python交互,都是事务,所以要用commit()提交事务 if qw = 1: conn.commit() except Exception, e: print e # 如果出错,则回滚之前的操作 conn.rollback() finally: # 先关闭游标 cursor.close() # 再关闭数据库连接 conn.close() print "执行结束!ok" if __name__ == "__main__": insert_data()
私有化
# coding = utf-8
class Test():
def __init__(self):
self.num = 10
self.__string = "hello world"
def __PrivateFunc(self):
print self.num
print self._string
def PublicFunc(self):
print self.num
print self._string
if __name__ == "__main__":
t = Test()
#t.PublicFunc()
#print t.num
#t.__PrivateFunc()
print t._string