2. 程式人生 > >mysql筆記三-----sql儲存過程、事務的隔離級別和sql各查詢的區別、防黑

mysql筆記三-----sql儲存過程、事務的隔離級別和sql各查詢的區別、防黑

阿新 • • 發佈：2019-02-02
  • 儲存過程

※※儲存過程※※※
定義：
create procedure 過程名(引數)
begin
  多條sql語句
end

呼叫：
call 過程名(實參)

例項1--無參的儲存過程：
△小細節：要把預設的語句結束“;”號改成其它如“$$”，這樣儲存過程中定義的分號就不被看成是語句結束(否則會直接被提交)。最後再把“;”號還原成預設的結束符。

delimiter $$
create procedure p1()
begin
  insert into stud values('P0010','小李',23);
  select * from stud;
end$$
delimiter ;
 


call p1();


例項2--有參的儲存過程：
delimiter $$
create procedure p2( in id varchar(32), in nm varchar(30), in age int )
begin
   insert into stud values(id,nm,age);
   select * from stud;
end$$
delimiter ;

call p2('P011','小五',28);

例項3--有返回值的儲存過程：
delimiter $$
create procedure p3( in id varchar(32), in nm varchar
 
(30), in age int, out num int )
begin
   insert into stud values(id,nm,age);
   select * from stud;
   select count(*) into num from stud;
end$$
delimiter ;

CALL p3('P012','小小五',27, @aa); /*呼叫且用aa接收結果*/

SELECT @aa;  /*顯示使用者變數aa*/
系統變數名稱：@@變數名
使用者變數名稱：@變數名

//////////binary////////////////
mysql查詢預設是不區分大小寫的如：
select * from? table_name where
 
? a like? 'a%'??? 
select * from? table_name where? a like? 'A%'??? 
select * from table_name where a like 'a%'
select * from table_name where a like 'A%'
效果是一樣的。

要讓mysql查詢區分大小寫，可以：
select? * from? table_name where? binary? a like? 'a%'??
select? * from? table_name where? binary? a like? 'A%'???
select * from table_name where binary a like 'a%'
select * from table_name where binary a like 'A%'
也可以在建表時，加以標識? 
create table table_name(
  a varchar(20) binary
)

/////事務處理////
DELETE FROM stud WHERE id='P006';
START TRANSACTION;
DELETE FROM stud WHERE id='P011';
UPDATE stud SET NAME='abc' WHERE id='P003';
ROLLBACK  /   COMMIT;

說明：從"START TRANSACTION"開始 到 “ROLLBACK; 或 COMMIT; ”，這中間的那麼語句是一個整體，如果執行 “ROLLBACK”，那麼這些動作都會回滾(撤消)。如果執行“COMMIT”，就全部執行成功。

////Java實現事務處理的簡單模板////
// /////////以下演示Java中如何實現事務////////////
// /////////以下演示Java中如何實現事務////////////
try {
    con.setAutoCommit(false);// 對應mysql中的“START TRANSACTION;”的功能

    String sql = "INSERT INTO sstud VALUES('1017','楊過',30,'武俠','1')";
    st.execute(sql);// 增
    sql = "delete from sstud where sno='1015' ";
    st.execute(sql);// 刪
    //sql = "update sstud set saddresos='中國北京' where sname='劉備' ";// 注意，這種方式不能寫多條sql語句(中間用分號隔也不行)
    sql = "update sstud set saddress='中國北京' where sname='劉備' ";// 注意，這種方式不能寫多條sql語句(中間用分號隔也不行)
    st.execute(sql);// 改

    con.commit();
    System.out.println("事務提交了.....");
} catch (Exception e) {
    System.out.println("事務回滾了.....");
    con.rollback();
}
  • 事務隔離

這裡寫圖片描述

查詢事務隔離級別：
select @@tx_isolation;

設定事務隔離級別(read-uncommitted)：set session transaction isolation level read uncommitted;//可以讀到沒有其他客戶端提交的

設定事務隔離級別(read-committed)：set session transaction isolation level read committed;//可以讀到其他客戶端提交的資訊

設定事務隔離級別(repeatable-read，預設)：set session transaction isolation level repeatable read;//其他客戶端操作對自己不會有影響

設定事務隔離級別(serializable，最高級別)：set session transaction isolation level serializable;//相當於單執行緒操作，在進行查詢時就會對錶或行加上共享鎖，其他事務對該表將只能進行讀操作，而不能進行寫操作

  • sql查詢，防黑
package cn.hncu.demo;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Scanner;

import org.junit.Test;


import cn.hncu.utils.ConnectFactory;

public class JdbcDemo {
    Connection con=ConnectFactory.getCon();
    /*Statement中有4個執行方法可用
     * 1, executeQuery() : 只能執行查詢語句
     * 2, executeUpdate(): 只能增、刪、改, 不能執行查詢語句
     * 3, execute(): 增、刪、改、查的語句都能夠執行。只是查詢時返回的結果是告訴成功與否，如果要獲取查詢結果，得另外用" st.getResultSet()"獲取
     * 4, executeBatch()//批處理，可以處理多條語句
     */
    @Test
    public void results() throws SQLException{
        Statement st=con.createStatement();
        String sql="select * from book";
        ResultSet rs=st.executeQuery(sql);
        while(rs.next()){
            Integer id=rs.getInt(1);
            String name=rs.getString("name");
            Double price=rs.getDouble(3);
            String birth=rs.getDate(4)+" "+rs.getTime(4);//注意獲取日期時間型資料的方式
            System.out.println(id+","+name+","+price+","+birth);
        }
        con.close();
    }
    @Test
    public void execute() throws SQLException{
        Statement st=con.createStatement();
        String sql=null;
        //      sql="INSERT INTO book(NAME,price,birth) VALUES('oracle',50.11,'2015-8-8 19:33:10')";
        //      sql="DELETE FROM book WHERE name='oracle';";
        sql="update  book set price=price*1.8 where name='sql'";
        st.execute(sql);
        results();
    }
    @Test
    public void executeUpdate() throws Exception{ 
        Statement st=con.createStatement();
        String sql=null;
        //              sql="INSERT INTO book(NAME,price,birth) VALUES('oracle',50.11,'2015-8-8 19:33:10')";
        sql="DELETE FROM book WHERE name='oracle';";
        //sql="update  book set price=price*1.8 where name='sql'";
        int num=st.executeUpdate(sql);//返回值是影響的行數
        System.out.println(num);
        results();
    }
    @Test //容易產生bug：如輸入name值為: b'c
    public void reg() throws Exception{ 
        Statement st=con.createStatement();
        Scanner sc=new Scanner(System.in);
        String id=sc.nextLine();
        String name =sc.nextLine();
        Integer age=Integer.parseInt(sc.nextLine());
        String sql="INSERT INTO stud(id,name,age) values('"+id+"','"+name+"',"+age+")";
        boolean boo=st.execute(sql);//不能用boolean來判斷，因為返回時ResultSet才是YES
        //      if(boo){
        //          System.out.println("註冊成功");
        //      }else {
        //          System.out.println("註冊失敗");
        //      }
    }
    @Test //容易產生bug：如輸入name值為: 'a' or '1=1
    public void login() throws Exception{ 
        Statement st=con.createStatement();
        Scanner sc=new Scanner(System.in);
        String id=sc.nextLine();
        String name =sc.nextLine();
        String sql=null;
        sql="select  count(*) from stud where id='"+id+"' and name='"+name+"'";
        ResultSet rs=st.executeQuery(sql);
        rs.next();
        int n = rs.getInt(1);
        System.out.println(sql);
        if(n<=0){
            System.out.println("登入失敗");
        }else {
            System.out.println("登入成功");
        }
        con.close();
    }
    //採用PrepareStatement
    @Test //不會被黑：如輸入name值為: a' or '1'='1
    public void login2() throws Exception{
        Statement st=con.createStatement();
        Scanner sc=new Scanner(System.in);
        String id=sc.nextLine();
        String name =sc.nextLine();
        String sql=null;
        sql="select  count(*) from stud where id=? and name=?";
        //建立預處理語句物件
        PreparedStatement ps=con.prepareStatement(sql);
        //給佔位設定值---設定引數
         //給第1個引數設定
        ps.setString(1, id);
        //給第2個引數設定
        ps.setString(2, name);
        ResultSet rs =ps.executeQuery();//不接受引數
        rs.next();
        int n = rs.getInt(1);
        if(n<=0){
            System.out.println("登入失敗...");
        }else{
            System.out.println("登入成功....");
        }

        con.close();
    }
    @Test//獲取自動增長列的值
    public void  getAuto() throws SQLException{
        Statement st=con.createStatement();
        String sql="INSERT INTO book(NAME,price,birth) VALUES('紅樓夢',100.11,'2015-5-8 19:23:10');";
        st.execute(sql, Statement.RETURN_GENERATED_KEYS);//需要呼叫Statement.RETURN_GENERATED_KEYS
        ResultSet rs=st.getGeneratedKeys();
        while(rs.next()){
            int id=rs.getInt(1);
            System.out.println("自動增長的值"+id);
        }
    }
    @Test//獲取自動增長列的值PrepareStatement
    public void  getAuto2() throws SQLException{
        String sql="INSERT INTO book(NAME,price,birth) VALUES(?,?,'2015-5-8 19:23:10');";
        PreparedStatement ps=con.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);
        ps.setString(1, "西遊記");
//      ps.setInt(2, 59);//能插入，但是會報錯！
        ps.setDouble(2, 60.9);
        ps.execute();
        ResultSet rs=ps.getGeneratedKeys();
        while(rs.next()){
            int id=rs.getInt(1);
            System.out.println("自動增長的值"+id);
        }
    }
    @Test 
    /*執行批處理---自己本身不帶事務，如果其中某條sql掛，則後續的sql執行失敗，
    前面的還是有效的。如果要事務，另外再採用:con.setAutoCommit(false)+
    try-cacth+ rollback/commit*/
    public void batchDemo() throws SQLException{
        Statement st=con.createStatement();
        String sql="INSERT INTO book(NAME,price,birth) VALUES('aa',2,'2016-5-8 19:23:10')";//有沒有分號都一樣
        for(int i=0;i<5;i++){
//          if(i==3){
//              sql="INSERT INTO book(NAME,price,birth) VALUES('aa,2,'2016-5-8 19:23:10')";//有沒有分號都一樣
//          }
            st.addBatch(sql);
        }
        int[] nums=st.executeBatch();
        for(int i=0;i<nums.length;i++){
            System.out.println(nums[i]);
        }
        System.out.println(nums.length);
    }
    @Test
    public void prepBatchDemo() throws SQLException{
        String sql="INSERT INTO book(NAME,price,birth) VALUES(?,?,'2016-5-8 19:23:10')";//有沒有分號都一樣
        PreparedStatement ps=con.prepareStatement(sql);
        for(int i=0;i<5;i++){
            ps.setString(1, "大話西遊");
            ps.setDouble(2, 100.5);
            ps.addBatch();
        }
        int[] nums=ps.executeBatch();
        for(int i=0;i<nums.length;i++){
            System.out.println(nums[i]);
        }
        System.out.println(nums.length);
    }
}

這是Connect工具類（單例)）

package cn.hncu.utils;

import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;

public class ConnectFactory {
    private static Connection con=null;
    static{
        try {
            Properties p=new Properties();
            p.load(ConnectFactory.class.getClassLoader().getResourceAsStream("jdbc.properities"));
            String url=p.getProperty("url");
            String user=p.getProperty("user");
            String password=p.getProperty("password");
            con=DriverManager.getConnection(url, user, password);
        } catch (IOException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    public static Connection getCon(){
        return con;
    }
    public static void main(String[] args) {
        System.out.println(getCon());
    }
}

相關推薦

重新學習MySQL資料庫9：Innodb中的事務隔離級別和鎖的關係

本文出自我的公眾號：程式設計師江湖。 滿滿乾貨，關注就送。 轉自https://tech.meituan.com/innodb-lock.html Innodb中的事務隔離級別和鎖的關係 前言: 我們都知道事務的幾種性質，資料庫為了維護這些性質，尤其是一致性和

mysql筆記三-----sql儲存過程、事務的隔離級別和sql各查詢的區別、防黑

儲存過程 ※※儲存過程※※※ 定義： create procedure 過程名(引數) begin 多條sql語句 end 呼叫： call 過程名(實參) 例項1--無參的儲存過程： △小細節：要把預設的語句結束“;”號改成其它如“$$”，

oracle,mysql,sql server三大數據庫的事務隔離級別查看方法

glob declare ddr 存在 lag har oca flag ali 1：mysql的事務隔離級別查看方法 mysql 最簡單，執行這條語句就行：select @@tx_isolation 詳情： 1.查看當前會話隔離級別 sel

理解mysql的鎖、事務隔離級別及事務傳播行為

資料庫事務(Database Transaction) ，是指作為單個邏輯工作單元執行的一系列操作，要麼完全地執行，要麼完全地不執行。 ACID，是指在可靠資料庫管理系統（DBMS）中，事務(Transaction)所應該具有的四個特性：原子性（Atomicity）、一致性（Consis

什麽是事務、事務特性、事務隔離級別、spring事務傳播特性

ons pri table 產生 serializa support enc 不一致 修改 1.什麽是事務： 事務是程序中一系列嚴密的操作，所有操作執行必須成功完成，否則在每個操作所做的更改將會被撤銷，這也是事務的原子性（要麽成功，要麽失敗）。 2.事務特性： 事務特性分為

Spring 的事務傳播型別、事務隔離級別

事務傳播型別 spring 的7種事務傳播型別 PROPAGATION_REQUIRED： 如果當前沒有事務，則建立一個新事務；如果當前存在事務，就加入該事務；該配置是最常用的設定。 PROPAGAT

異步、事務隔離級別及緩存優化

同仁 我們 作用域 復制 object ctx eas 存在 ace 異步 既然是異步我們就得知道我們知道在什麽情況下需要使用異步編程，當等待一個比較耗時的操作時，可以用異步來釋放當前的托管線程而無需等待，從而在管理線程中不需要花費額外的時間，也就是不會阻塞當前線程的運行。

一文講清楚MySQL事務隔離級別和實現原理，開發人員必備知識點

經常提到資料庫的事務，那你知道資料庫還有事務隔離的說法嗎，事務隔離還有隔離級別，那什麼是事務隔離，隔離級別又是什麼呢？本文就幫大家梳理一下。 MySQL 事務 本文所說的 MySQL 事務都是指在 InnoDB 引擎下，MyISAM 引擎是不支援事務的。 資料庫事務指的是一組資料操作，事務內的操作要麼就是

Spring事務隔離級別和傳播特性

我們 head ttr and frame 自己的 傳播行為 nag key 傳播行為 事務的第一個方面是傳播行為。傳播行為定義關於客戶端和被調用方法的事務邊界。Spring定義了7中傳播行為。 傳播行為 意義 PROPAGATION_MANDATORY

數據庫事務隔離級別和鎖實現機制

約定 表鎖 四種 back 數據庫操作 升級 數據對象 三級封鎖 pro 1. 數據庫事務處理中出現的數據不一致的情況 在多個事務並發做數據庫操作的時候，如果沒有有效的避免機制，就會出現種種問題。大體上有四種問題，歸結如下： 1.1 丟失更新 如果兩個事務都要更新數據庫一個

事務隔離級別和傳播機制

2.事務隔離級別分類 事務隔離級別由低往高可分為以下幾類： READ UNCOMMITTED 讀取未提交的資料。這是最不安全的一種級別，查詢語句在無鎖的情況下執行，並能讀取到別的未提交的資料，造成髒讀，如果未提交的那個 事務資料全部回滾了，而之前讀取了這個事務的資料即是髒資料，這種資料不

Spring事務 隔離級別和傳播行為

TransactionDefinition.ISOLATION_DEFAULT：這是預設值，表示使用底層資料庫的預設隔離級別。對大部分資料庫而言，通常這值就是TransactionDefinition.ISOLATION_READ_COMMITTED。 TransactionDefinition.ISOLA

InnoDB中事務隔離級別和鎖的關係 思路？個人理解？

1 資料庫遵循兩段鎖協議，加鎖階段和解鎖階段，在對任何資料進行讀操作之前要申請並獲得S鎖，在寫操作之前要申請並獲得X鎖 2 事務中的加鎖方式，事務的四種隔離級別，未提交讀，已提交讀（RC），可重複讀（RR），可序列化，各種隔離級別

Hibernate事務隔離級別和事務傳播特性

事務隔離級別： 　　1：讀操作未提交(Read Uncommitted) 　　2：讀操作已提交(Read Committed) 　　4：可重讀(Repeatable Read) 　　8：可序列化(Serializable) 　　事務傳播特性： 　　1.PROPAGATION

資料庫中的事務隔離級別和鎖的關係

我們都知道事務的幾種性質，資料庫為了維護這些性質，尤其是一致性和隔離性，一般使用加鎖這種方式。同時資料庫又是個高併發的應用，同一時間會有大量的併發訪問，如果加鎖過度，會極大的降低併發處理能力。所以對於加鎖的處理，可以說就是資料庫對於事務處理的精髓所在。這裡通過分析MyS

Innodb中的事務隔離級別和鎖的關係

前言: 我們都知道事務的幾種性質，資料庫為了維護這些性質，尤其是一致性和隔離性，一般使用加鎖這種方式。同時資料庫又是個高併發的應用，同一時間會有大量的併發訪問，如果加鎖過度，會極大的降低併發處理能力。所以對於加鎖的處理，可以說就是資料庫對於事務處理的精髓所在。這裡通過

Innodb中的事務隔離級別和鎖的關係 美團技術部落格

前言: 我們都知道事務的幾種性質，資料庫為了維護這些性質，尤其是一致性和隔離性，一般使用加鎖這種方式。同時資料庫又是個高併發的應用，同一時間會有大量的併發訪問，如果加鎖過度，會極大的降低併發處理能力。所以對於加鎖的處理，可以說就是資料庫對於事務處理的精髓所在。這裡通過分析

mysql筆記三之條件、模糊、範圍查詢

1.-- 條件查詢 滿足條件 就能夠進入結果集     -- 比較運算子         -- >         -- 查詢大於18歲的資

mysql資料庫學習11-儲存過程、函式、觸發器

儲存的程式 ========================================   * 資料庫中儲存的程式，對資料進行運算處理      * 儲存過程   * 函式   * 觸發器    會話變數

mysql儲存過程迴圈事務插入資料

DROP PROCEDURE IF EXISTS insertTUserStatement; create procedure insertTUserStatement(IN num int) begin declare i int; start transac