1. 程式人生 > 其它 >MySQL---儲存過程詳解

MySQL---儲存過程詳解

1.儲存過程的簡介
我們常用的操作資料庫語言SQL語句在執行的時候需要要先編譯,然後執行,而儲存過程(Stored Procedure)是一組為了完成特定功能的SQL語句集,經編譯後儲存在資料庫中,使用者通過指定儲存過程的名字並給定引數(如果該儲存過程帶有引數)來呼叫執行它。

一個儲存過程是一個可程式設計的函式,它在資料庫中建立並儲存。它可以有SQL語句和一些特殊的控制結構組成。當希望在不同的應用程式或平臺上執行相同的函式,或者封裝特定功能時,儲存過程是非常有用的。資料庫中的儲存過程可以看做是對程式設計中面向物件方法的模擬。它允許控制資料的訪問方式

2.儲存過程優點
儲存過程增強了SQL語言的功能和靈活性

。儲存過程可以用流控制語句編寫,有很強的靈活性,可以完成複雜的判斷和較複雜的運算。

儲存過程允許標準組件是程式設計。儲存過程被建立後,可以在程式中被多次呼叫,而不必重新編寫該儲存過程的SQL語句。而且資料庫專業人員可以隨時對儲存過程進行修改,對應用程式原始碼毫無影響。

儲存過程能實現較快的執行速度。如果某一操作包含大量的Transaction-SQL程式碼或分別被多次執行,那麼儲存過程要比批處理的執行速度快很多。因為儲存過程是預編譯的。在首次執行一個儲存過程時查詢,優化器對其進行分析優化,並且給出最終被儲存在系統表中的執行計劃。而批處理的Transaction-SQL語句在每次執行時都要進行編譯和優化,速度相對要慢一些。

儲存過程能過減少網路流量。針對同一個資料庫物件的操作(如查詢、修改),如果這一操作所涉及的Transaction-SQL語句被組織程儲存過程,那麼當在客戶計算機上呼叫該儲存過程時,網路中傳送的只是該呼叫語句,從而大大增加了網路流量並降低了網路負載。

儲存過程可被作為一種安全機制來充分利用。系統管理員通過執行某一儲存過程的許可權進行限制,能夠實現對相應的資料的訪問許可權的限制,避免了非授權使用者對資料的訪問,保證了資料的安全。

3.儲存過程缺點
不易維護,一旦邏輯變了修改起來麻煩
如果寫此儲存過程的人離職了,對於接手她程式碼的人估計是一場災難,因為別人還要去讀懂你程式邏輯,還要讀懂你儲存邏輯。不利於擴充套件。
最大的缺點! 雖然儲存過程可以減少程式碼量,提高開發效率。但是有一點非常致命的就是太耗效能。
4.儲存過程的語法
4.1 建立儲存過程

create procedure sp_name()
begin
.........
end

4.2 呼叫儲存過程

call sp_name()

注意:儲存過程名稱後面必須加括號,哪怕該儲存過程沒有引數傳遞

4.3 刪除儲存過程

drop procedure sp_name//

注意:不能在一個儲存過程中刪除另一個儲存過程,只能呼叫另一個儲存過程

4.4其他常用命令

show procedure status

顯示資料庫中所有儲存的儲存過程基本資訊,包括所屬資料庫,儲存過程名稱,建立時間等

show create procedure sp_name

顯示某一個MySQL儲存過程的詳細資訊

5.MyBatis呼叫MySQL儲存過程的案例實現

5.1案例的簡單描述

案例主要以一個簡單的統計某種名稱裝置的總數來實現。

5.2 資料庫表的建立

DROP TABLE IF EXISTS `cus_device`;
CREATE TABLE `cus_device` (
  `device_sn` varchar(20) NOT NULL COMMENT '裝置編號',
  `device_cat_id` int(1) DEFAULT NULL COMMENT '裝置型別',
  `device_name` varchar(64) DEFAULT NULL COMMENT '裝置名稱',
  `device_type` varchar(64) DEFAULT NULL COMMENT '裝置型號',
  PRIMARY KEY (`device_sn`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

5.3 建立儲存過程

以裝置的名稱為輸入引數,以統計到裝置的總數為輸出引數

DROP PROCEDURE IF EXISTS `countDevicesName`;
DELIMITER ;;
CREATE  PROCEDURE `countDevicesName`(IN dName VARCHAR(12),OUT deviceCount INT)
BEGIN
SELECT COUNT(*) INTO deviceCount  FROM cus_device WHERE device_name = dName;

END
;;
DELIMITER ;

5.4 Mybatis呼叫MySQL儲存過程

1. mybatis-config.xml
<?xml version="1.0" encoding="UTF-8" ?>  
<!DOCTYPE configuration PUBLIC   
    "-//mybatis.org//DTD Config 3.0//EN"  
    "http://mybatis.org/dtd/mybatis-3-config.dtd">  
<configuration>  

    <settings>
    <!-- 列印查詢語句 -->
        <setting name="logImpl" value="STDOUT_LOGGING" />
    </settings>
    <!-- 配置別名 -->  
    <typeAliases>  
        <typeAlias type="com.lidong.axis2demo.DevicePOJO" alias="DevicePOJO" />   
    </typeAliases>  

    <!-- 配置環境變數 -->  
    <environments default="development">  
        <environment id="development">  
            <transactionManager type="JDBC" />  
            <dataSource type="POOLED">  
                <property name="driver" value="com.mysql.jdbc.Driver" />  
                <property name="url" value="jdbc:mysql://127.0.0.1:3306/bms?characterEncoding=GBK" />  
                <property name="username" value="root" />  
                <property name="password" value="123456" />  
            </dataSource>  
        </environment>  
    </environments>  

    <!-- 配置mappers -->  
    <mappers>  
        <mapper resource="com/lidong/axis2demo/DeviceMapper.xml" />  
    </mappers>  

</configuration>
2. CusDevice.java
public class DevicePOJO{

     private String devoceName;//裝置名稱
     private String deviceCount;//裝置總數


    public String getDevoceName() {
        return devoceName;
    }
    public void setDevoceName(String devoceName) {
        this.devoceName = devoceName;
    }
    public String getDeviceCount() {
        return deviceCount;
    }
    public void setDeviceCount(String deviceCount) {
        this.deviceCount = deviceCount;
    }
}
3. DeviceDAO的實現
package com.lidong.axis2demo;

public interface DeviceDAO {

    /**
     * 呼叫儲存過程 獲取裝置的總數
     * @param devicePOJO
     */
    public void count(DevicePOJO devicePOJO);

}
4.Mapper的實現
<?xml version="1.0" encoding="UTF-8" ?>  
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.lidong.axis2demo.DeviceDAO">

    <resultMap id="BaseResultMap" type="CusDevicePOJO">
        <result column="device_sn" property="device_sn" jdbcType="VARCHAR" />
    </resultMap>

    <sql id="Base_Column_List">
        device_sn, device_name,device_mac
    </sql>

    <select id="count" parameterType="DevicePOJO" useCache="false"
        statementType="CALLABLE">  
        <![CDATA[ 
        call countDevicesName(
        #{devoceName,mode=IN,jdbcType=VARCHAR},
        #{deviceCount,mode=OUT,jdbcType=INTEGER});
        ]]>
    </select>
</mapper>  

注意:statementType=”CALLABLE” 必須為CALLABLE,告訴MyBatis去執行儲存過程, 否則會報錯
Exception in thread “main” org.apache.ibatis.exceptions.PersistenceException

mode=IN 輸入引數 mode=OUT輸出引數 jdbcType為資料庫定義的欄位型別。
這樣寫 Mybatis會幫助我們自動回填輸出的deviceCount的值。

5.測試

package com.lidong.axis2demo;

import java.io.IOException;
import java.io.Reader;

import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
/**
 * MyBatis 執行儲存過程
 * @author Administrator
 *
 */
public class TestProduce {

    private static SqlSessionFactoryBuilder sqlSessionFactoryBuilder;  
    private static SqlSessionFactory sqlSessionFactory;  
    private static void init() throws IOException {  
        String resource = "mybatis-config.xml";  
        Reader reader = Resources.getResourceAsReader(resource);  
        sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();  
        sqlSessionFactory = sqlSessionFactoryBuilder.build(reader);  
    }  

    public static void main(String[] args) throws Exception {
        testCallProduce();
    }

    /**
     * @throws IOException
     */
    private static void testCallProduce() throws IOException {
        init();
        SqlSession session= sqlSessionFactory.openSession();  
        DeviceDAO deviceDAO = session.getMapper(DeviceDAO.class);  
        DevicePOJO device = new DevicePOJO();  
        device.setDevoceName("裝置名稱");  
        deviceDAO.count(device);
        System.out.println("獲取"+device.getDevoceName()+"裝置的總數="+device.getDeviceCount());
    }

}

結果