创建用户
CREATE USER `root`@`127.0.0.1` IDENTIFIED BY 'passowrd';
GRANT ALL ON *.* TO `root`@`127.0.0.1` WITH GRANT OPTION;
数据操作
逐条插入数据
insert into tablename(col1,col2) values ('%s','%d') % (val1,val2)
insert into tablename(col1,col2) values ('1','2')
表操作
创建表
create table house(
name varchar(200) NOT NULL,
area varchar(200),
address varchar(200),
type_how_big varchar(100),
type_howmany_room varchar(500),
type_which_floor varchar(100),
type_direction varchar(100),
type_time varchar(100),
price varchar(100),
junjia varchar(500),
city varchar(50),
page integer
);
drop,delete,truncate区别
truncate 清洗表数据,但保留表结构
drop 删除表,不可回滚
delete 删除表,可回滚
- truncate和 delete只删除数据不删除表的结构(定义)
drop语句将删除表的结构被依赖的约束(constrain),触发器(trigger),索引(index); 依赖于该表的
存储过程/函数将保留,但是变为invalid状态. - delete语句是dml,这个操作会放到rollback segement中,事务提交之后才生效;如果有相应的trigger,
执行的时候将被触发.
truncate,drop是ddl, 操作立即生效,原数据不放到rollback segment中,不能回滚. 操作不触发
trigger. - delete语句不影响表所占用的extent, 高水线(high watermark)保持原位置不动
显然drop语句将表所占用的空间全部释放
truncate 语句缺省情况下见空间释放到 minextents个 extent,除非使用reuse storage; truncate
会将高水线复位(回到最开始). - 速度,一般来说: drop> truncate > delete
- 安全性:小心使用drop 和truncate,尤其没有备份的时候.否则哭都来不及.
使用上,想删除部分数据行用delete,注意带上where子句. 回滚段要足够大.
想删除表,当然用drop
想保留表而将所有数据删除. 如果和事务无关,用truncate即可. 如果和事务有关,或者想触发trigger,还
是用delete.
如果是整理表内部的碎片,可以用truncate跟上reuse stroage,再重新导入/插入数据/
查询表中数据量
SELECT COUNT(*) FROM table_name;
pymysql使用
连接数据库
import pymysql
def dbHandle():
try:
conn = pymysql.connect(
host="localhost",# 主机名
db="sofang",# 数据库名
port=3306,
user="root",
passwd="root",
charset="utf8",
use_unicode=True,
)
except OperationalError as e:
print e
return conn
查询数据库
def select(self,table_name):
#sql语句之间应该有空格
sql = 'select * from '+table_name+';'
cursor = self.conn.cursor() #创建游标
cursor.execute(sql) #执行sql
self.conn.commit() #提交
#将查询的数据打印出来
results = cursor.fetchall()
for row in results:
print row
批量插入数据
def insert_inspection_list(self,table_name):
for i in range(1,100):
id = str(i)
inspection_num = 'NJ'+ str(100000+i)
car_id = i+1
create_time = time.strftime('%Y-%m-%d %H:%M:%S',time.localtime())
update_time = time.strftime('%Y-%m-%d %H:%M:%S',time.localtime())
#@@@@@字符串用双引号加单引号"''",三种sql语句
sql1 = 'insert into car (id,inspection_num,car_id, create_uid) values
('+id+',"' + inspection_num + '",' + car_id + ',238);
sql2 = 'insert into car (id,inspection_num,car_id,create_uid,create_time,
update_time)values({},{},{},{},{},{})'.format(id,inspection_num,car_id,238,create_time,
update_time)
sql3 = 'insert into car (id,inspection_num,car_id,create_uid,create_time,
update_time)values (%s,%s,%d,%s,%s,%s)' % (id, inspection_num, car_id, 238, create_time,
update_time)
print sql
cursor = self.conn.cursor()
cursor.execute(sql)
self.conn.commit()
关闭数据库
def close(self):
self.conn.close()