Pymysql

时间  2019-11-11
标签 pymysql 栏目 MySQL 繁體版
原文   原文链接

1、Pymysql前端

在增删改文档的时候，必需要加上.commit确保修改的成功python

#pip3 install pymysql #安装pymysql模块,在python中可使用于mysql之间交互

import pymysql
client=pymysql.connect(
    host='127.0.0.1',
    port=3306,
    user='root',
    password='yf123',
    database='db4',
    charset='utf8'
)
cursor=client.cursor()
#mysql邮标是接受sql语句在cmd中,而python中是以cursor为邮标
sql='insert into t1 values(2,"yf");'#sql语句
try:
    res=cursor.execute(sql)#execute执行的意思
    print(res)
    client.commit() #改操做必定要commit
except Exception:
    client.rollback()
cursor.close()#关闭邮标
client.close()#回收套接字资源

2、增长,删除mysql

增长sql

#pip3 install pymysql #安装pymysql模块,在python中可使用于mysql之间交互
import pymysql

client=pymysql.connect(
    host='127.0.0.1',
    port=3306,
    user='root',
    password='yf123',
    database='db4',
    charset='utf8'
)
cursor=client.cursor()
#mysql邮标是接受sql语句在cmd中,而python中 是以cursor为邮标
userinfo=[
    (6,"cq"),
    (7,"zz"),
    (8,"hb")
]

# for user in userinfo:
sql='insert into t1 values(%s,%s);'#sql语句
#
#     res=cursor.execute(sql)#execute执行的意思
cursor.executemany(sql,userinfo)#executemany就是循环出userinfo,不须要for循环
client.commit() #改操做必定要commit
cursor.close()#关闭邮标
client.close()#回收套接字资源

删除数据库

import pymysql

client=pymysql.connect(
    host='127.0.0.1',
    port=3306,
    user='root',
    password='yf123',
    database='db4',
    charset='utf8'
)
cursor=client.cursor()
cursor.execute('delete from t1 where id=3;')

client.commit() #改操做必定要commit

cursor.close()#关闭邮标
client.close()#回收套接字资源

3、调用存储过程后端

 

在密码前输入password能够起到加密做用异步

 

 

 

在密码输入以后会到数据库进行对比，若是有结果出来就表明输入的账号密码是正确的ide

 

 

 

每次删记录，针对默认递增的，若是下次注册信息不手动填补以前删除的id那么会形成跳空，直接按照最后一次的序列号继续下去，若是手动填补了以前的删除id，就算后面手动继续输入id存储，默认id递增序列也会自动跟从函数

 

 

 

在mysql中--是同一行注释后面的内容oop

 

Xxx” -- xxxxx

 

Xxx” or 1=1 -- hellsb

 

Mysql里面  没有密码或者账号也能登入数据库，因此在前端以及后端都须要加防，特殊字符的取消

 

import pymysql

client=pymysql.connect(
    host='127.0.0.1',
    port=3306,
    user='root',
    password='yf123',
    database='db4',
    charset='utf8'
)
cursor=client.cursor(pymysql.cursors.DictCursor)
#查询
inp_user=input("输入帐号名：").strip()
inp_pwd=input("输入密码：").strip()

sql='select id from user where name = "%s" and pwd = "%s";' %(inp_user,inp_pwd)
rows = cursor.execute(sql)
if rows:
    print("登入成功")
else:
    print("用户名或者密码错误")


cursor.close()#关闭邮标
client.close()#回收套接字资源

 

client=pymysql.connect(
    host='127.0.0.1',
    port=3306,
    user='root',
    password='yf123',
    database='db4',
    charset='utf8'
)
cursor=client.cursor(pymysql.cursors.DictCursor)#将fetchall拿到的结果以一个大列表的形式,
# 里面的每个消息内都是以字典的形式进行显示
#查询
inp_user=input("输入帐号名：").strip()
inp_pwd=input("输入密码：").strip()

sql='select * from user where id > 3;'#执行sql语句不会在原地等,是异步过程
rows = cursor.execute(sql,(inp_user,inp_pwd)) #这种方式,会在用户输入帐号密码以后
# 传输以前进行一个检查是否有特殊符号
# print(rows)#是查询成功的行数
#内存中拿结果


# print(cursor.fetchall())#fetchall,查看全部的结果,以大元组的形式里面每个结果以小元组方式
# 用fetchall方式拿完一次,后面直接再拿就没法获取到
# cursor.scroll(0,mode="absolute")#绝对位置移动,在第一次fetchall取完内容以后,再用scroll方式
# absolute方法能够相似指针方式移动到最初位置,最前面的数字输入多少就是就是从最开始日后移动多少
# print(cursor.fetchall())


# print(cursor.fetchone())#每次拿一条信息
# cursor.scroll(2,mode="relative")#相对当前位置移动,在目前所在位置向后移动,前面的数字表明
# 移动的个数


# print(cursor.fetchmany(2))#是从查询结果当中拿的条数,括号内填写的数字是针对一次拿几条的信息

cursor.close()#关闭邮标
client.close()#回收套接字资源
提交查询语句而且拿到查询结果

四、视图

视图既是将虚拟表保存下来
create view student2score as select * from student inner join score on student.sid = student_id;

create view student2score as select student.*,score.sid as score_sid,student_id,course_id,num from student inner join score on student.sid = student_id;

须要注意的是：

建立视图须要create view student2score as

另外若是表里面有重复字段会报错

视图建立出来的表，只有表结构没有表内容，而表的内容都是经过查询语句每次查询出来的结果（另外两张表内），视图至关于就保存了sql语句，直接使用表不用每次链接表，不要去改视图里面的记录，主要是用查询，简化查询语句

强调
#一、字段名不能重复
#二、视图是为了简化查询的sql语句，不该该修改视图中的记录
删除视图
drop view student2score（视图名称）

 

5、触发器

针对记录的增删改行为自动触发
命名按照
create trigger(建立触发器) (tri(触发器) _before(针对以前仍是以后)_insert(针对什么行为)_tb1(哪张表))命名方式

 

# 插入前CREATE TRIGGER tri_before_insert_tb1 BEFORE INSERT ON tb1 FOR EACH ROW
BEGIN
    ...
END
# 插入后CREATE TRIGGER tri_after_insert_tb1 AFTER INSERT ON tb1 FOR EACH ROW
BEGIN
    ...
END
# 删除前CREATE TRIGGER tri_before_delete_tb1 BEFORE DELETE ON tb1 FOR EACH ROW
BEGIN
    ...
END
# 删除后CREATE TRIGGER tri_after_delete_tb1 AFTER DELETE ON tb1 FOR EACH ROW
BEGIN
    ...
END
# 更新前CREATE TRIGGER tri_before_update_tb1 BEFORE UPDATE ON tb1 FOR EACH ROW
BEGIN
    ...
END
# 更新后CREATE TRIGGER tri_after_update_tb1 AFTER UPDATE ON tb1 FOR EACH ROW
BEGIN
    ...
END
CREATE TABLE cmd (
    id INT PRIMARY KEY auto_increment,
    USER CHAR (32),
    priv CHAR (10),
    cmd CHAR (64),
    sub_time datetime, #提交时间
    success enum ('yes', 'no') #0表明执行失败
);

CREATE TABLE errlog (
    id INT PRIMARY KEY auto_increment,
    err_id int,
);
delimiter $$ #更改结束符号
CREATE TRIGGER tri_after_insert_cmd AFTER INSERT ON cmd FOR EACH ROW
BEGIN
    if NEW.success = 'no' then
        insert into errlog(err_id) values(NEW.id);
    end if;
END $$
delimiter ;

6、事务

 

transaction 事务,交易
事务能够包含一系列的sql语句,事务的执行具备原子性
一、原子性:
包含多条sql语句,要么都执行成功,要么都执行不成功
二、回滚
rollback，遇到状况就回滚到以前状态，就像什么都没发生过同样
start transaction;开启事务
在这里面作的全部修改若是遇到rollback就会回到原来的状态

start transaction;
try:
    update user set balance=900 where id=1;
    update user set balance=1010 where id=2;
    update user set balance=1090 where id=3;
    commit;
except Exception:
    rollback;

七、流程控制：

delimiter //
create procedure proc_while()
begin
    declare num int;
    set num = 0;
    while num < 10 do
        select
            num;
        set num = num+1;
    end while;
end //
delimiter;
while循环 
delimiter //
create procedure proc_repat()
begin
    declare i int;
    set i = 0;
    repeat
        select i;
        set i=i+1;
        until i>=5
    end repeat;
end//
delimiter;
repeat循环 
begin
    declare i int default 0;
    loop_label:loop
        set i=i+1;
        if i<8 then
            iterate loop_label;
        end if;
        if i>=10 then
            leave loop_label;
        end if;
        select i;
    end loop loop_label
end
loop循环

八、函数

 

select date_format(sub_time,"%Y-%m"),count(id) from blog group by date_format(sub_time,"%Y-%m");#不要单独使用，要在sql语句中使用

 

九、存储过程

delimiter $$
create procedure p1() #建到某一个库下,p1存储过程名
begin
       select * from blog;
end $$
delimiter ;

call p1()#用call进行调用存储过程，存储过程是一系列sql语句的结合体，里面能够用mysql里面的全部功能，
是mysql一堆功能的封装体，给应用程序用


create table s1(
id int,
name varchar(20),
gender char(6),
email varchar(50)
);#将表存放进

delimiter $$  #定义阶段
create procedure p2()
BEGIN
    declare n int default 1;
    while (n < 100000) do
        insert into s1 values(n,concat('yf',n),'male',concat('yf',n,'@163.com'));
        set n=n+1;
    end while;
END $$
delimiter ;
无参 
delimiter $$
create procedure p3(
    in n int,
    out res int      #进行返回
    inout x int       #既能传值也能得到返回值，用其中一个就行
)
begin
       select * from blog where id>3;
       set res = 0; #返回值
end $$
delimiter ;

针对out参数要传变量
set @x=111;
call p3(3,@x) #而后再调用 返回值为0就成功了
select @x;
+------+
| @x   |
+------+
|    0 |
+------+

在python中调用：
cursor.callproc('p4',(3,111)) #set @_p4_0 = 3; set @_p4_1 = 111
print(cursor.fetchall())
cursor.execute('select @_p4_1;')
print(cursor.fetchone())
有参
相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程