创建表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_bookTypeWHERE t_book.bookTypeId = t_bookType.id;select * from t_book, t_bookType where t_book.bookTypeId = t_bookType.id;# 隐式连接中# 给每张表起别名用:asSELECT tb.bookName, tb.price, tby.bookTypeNameFROM t_book as tb, t_bookType as tbyWHERE tb.bookTypeId = tby.id;# 显式连接SELECT tb.bookName, tb.price, tby.bookTypeNameFROM t_book as tbINNER JOIN t_bookType as tbyON tb.bookTypeId = tby.id;交集: 属于A集合,也 属于B集合 的数据, A & B并集: 属于A集合 和 属于B 的数据的全部集合, A | B(重复数据只保留一个)2. 左连接 : LEFT JOIN ON# 两张表连接查询,无论二者是否有数据缺失,一定会把左边的表数据全部显示出来SELECT *FROM t_bookLEFT JOIN t_bookTypeON t_book.bookTypeId = t_bookType.idSELECT tb.bookName, tb.price, tb.author, tby.bookTypeNameFROM t_book as tbLEFT JOIN t_bookType as tbyON tb.bookTypeId = tby.id3. 右连接: RIGHT JOIN ON# 两张表连接查询,无论二者是否有数据缺失,一定会把右边的表数据全部显示出来SELECT *FROM t_bookRIGHT JOIN t_bookTypeON t_book.bookTypeId = t_bookType.idSELECT tb.bookName, tb.price, tb.author, tby.bookTypeNameFROM t_book as tbRIGHT JOIN t_bookType as tbyON tb.bookTypeId = tby.id4. 全连接: UNION :# 两张表连接查询,无论二者是否有数据缺失,一定会都显示表数据全部显示出来SELECT tb.bookName, tb.price, tb.author, tby.bookTypeNameFROM t_book as tbLEFT JOIN t_bookType as tbyON tb.bookTypeId = tby.idUNIONSELECT tb.bookName, tb.price, tb.author, tby.bookTypeNameFROM t_book as tbRIGHT JOIN t_bookType as tbyON tb.bookTypeId = tby.idSELECT 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_bookWHERE bookTypeIdIN (SELECT id FROM t_bookType);2. 子查询: NOT IN:# 和 in相反,不在集合里的数据,才会匹配成功SELECT *FROM t_bookWHERE bookTypeIdNOT IN (SELECT id FROM t_bookType);3. 子查询:EXISTS 返回Bool值,如果子查询语句里查询成功,则返回True,否则返回FalseSELECT *FROM t_bookWHERE EXISTS(SELECT * FROM t_bookType);4. 子查询:NOT EXISTS: 对子查询语句返回的结果取反。SELECT *FROM t_bookWHERE 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=innodbshow create table students;开启事务:执行insert、update、delete语句时,变更会维护到本地缓存中,而不维护到物理表中begin;提交事务:将缓存中的数据变更维护到物理表中commit;回滚事务:放弃缓存中变更的数据rollback;示例1:提交步骤1:打开两个终端,连接mysql,使用同一个数据库,操作同一张表终端1select * from students;终端2:开启事务,插入数据begin;insert into students(sname) values('张飞');步骤2终端1:查询数据,发现并没有新增的数据select * from students;步骤3终端2:完成提交commit;终端1:查询,发现有新增的数据select * from students;示例2:回滚步骤1:打开两个终端,连接mysql,使用同一个数据库,操作同一张表终端1select * from students;终端2begin;insert into students(sname) values('张飞');步骤2终端1:查询数据,发现并没有新增的数据select * from students;步骤3终端2:完成回滚rollback;终端1:查询数据,发现没有新增的数据select * from students;
mysql与Python交互
# coding=utf-8import MySQLdbdef 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-8import MySQLdbdef 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-8import MySQLdbdef 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-8class 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._stringif __name__ == "__main__": t = Test() #t.PublicFunc() #print t.num #t.__PrivateFunc() print t._string