MySQL ストアド プロシージャの原理と使用法の詳細な説明

区切り文字 //
プロシージャ p1() を作成する
始める
  ブログから*を選択します。
  blog(name,sub_time) に値 ("xxx",now()) を挿入します。
終わり //
区切り文字 ;

#mysqlでp1()を呼び出す

#Python で pymysql に基づいて cursor.callproc('p1') を呼び出す
print(カーソル.fetchall())

mysql> emp から * を選択します。
+----+----------+-----+--------+
| ID | 名前 | 年齢 | dep_id |
+----+----------+-----+--------+
| 1 | 張さん | 18 | 1 |
| 2 | リシ | 19 | 1 |
| 3 | エゴン | 20 | 2 |
| 5 | アレックス | 18 | 2 |
+----+----------+-----+--------+
4 列セット (0.30 秒)
mysql> 区切り文字 //
mysql> プロシージャ p2 を作成します (n1 には int、n2 には int)
  -> 開始
  -> id >n1 かつ id <n2 の場合、emp から * を選択します。
  -> 終了 //
クエリは正常、影響を受けた行は 0 行 (0.28 秒)
mysql> 区切り文字;
mysql> p2(1,3) を呼び出す
  -> ;
+----+------+-----+--------+
| ID | 名前 | 年齢 | dep_id |
+----+------+-----+--------+
| 2 | リシ | 19 | 1 |
+----+------+-----+--------+
セット内の1行（0.07秒）
クエリは正常、影響を受けた行は 0 行 (0.07 秒)

#Python で pymysql に基づいて cursor.callproc('p2',(1,3)) を呼び出す
print(カーソル.fetchall())

mysql> 区切り文字 //
mysql> プロシージャ p3 を作成します (in n1 int、out res int)
  -> 開始
  -> id >n1 の場合、emp から * を選択します。
  ->res=1 を設定します。
  -> 終了 //
クエリは正常、影響を受けた行は 0 行 (0.28 秒)
mysql> 区切り文字;
mysql> @res=0 を設定します。
クエリは正常、影響を受けた行は 0 行 (0.00 秒)
mysql> p3(3,@res); を呼び出します。
+----+------+-----+--------+
| ID | 名前 | 年齢 | dep_id |
+----+------+-----+--------+
| 5 | アレックス | 18 | 2 |
+----+------+-----+--------+
セット内の 1 行 (0.00 秒)
クエリは正常、影響を受けた行は 0 行 (0.01 秒)
mysql> @res を選択します。
+------+
| @res |
+------+
| 1 |
+------+
セット内の 1 行 (0.00 秒)

#python の pymysql に基づいて cursor.callproc('p3',(3,0)) を呼び出します #0 は set @res=0 と同等です
print(cursor.fetchall()) #select のクエリ結果を照会します。cursor.execute('select @_p3_0,@_p3_1;') #@p3_0 は最初のパラメータを表し、@p3_1 は 2 番目のパラメータ、つまり戻り値を表します。print(cursor.fetchall())

区切り文字 //
プロシージャp4を作成します(
  入出力 n1 int
）
始める
  id > n1 のブログから * を選択します。
  n1 = 1 に設定します。
終わり //
区切り文字 ;

#mysqlでset @x=3を呼び出します。
p4(@x) を呼び出します。
@x を選択;

#Python で pymysql に基づいて cursor.callproc('p4',(3,)) を呼び出す
print(cursor.fetchall()) #select のクエリ結果を照会します。cursor.execute('select @_p4_0;')
print(カーソル.fetchall())

#導入区切り文字 //
      プロシージャp4を作成します(
        アウトステータス int
      ）
      始める
        1. 例外が発生した場合に{を実行することを宣言します。
          ステータスを 1 に設定します。
          ロールバック;
        }
        取引開始 - Qin Bing のアカウントから 100 を減算
          -- ファン・シャオウェイのアカウントに90を追加
          -- 張根のアカウントプラス10
          専念;
        終了ステータスを 2 に設定します。
      終わり //
      区切り文字 ;
#区切り文字を実装する //
プロシージャp5を作成します(
  OUT p_return_code tinyint
）
始める 
  sqlexception の終了ハンドラを宣言する 
  始める 
     -  エラー 
    p_return_codeを1に設定します。 
    ロールバック; 
  終わり; 
  sqlwarning の終了ハンドラを宣言する 
  始める 
     - 警告 
    p_return_codeを2に設定します。 
    ロールバック; 
  終わり; 
  トランザクションを開始します。 
    DELETE from tb1; #実行に失敗しました insert into blog(name,sub_time) values('yyy',now());
  専念; 
   - 成功 
  p_return_code = 0 を設定します。#0 は実行成功を表します END //
区切り文字 ;

#mysql のストアド プロシージャを呼び出します。@res=123 を設定します。
p5(@res) を呼び出します。
@res を選択します。

#python で pymysql に基づくストアド プロシージャを呼び出す cursor.callproc('p5',(123,))
print(cursor.fetchall()) #select のクエリ結果を照会します。cursor.execute('select @_p5_0;')
print(カーソル.fetchall())

-- パラメータなしでproc_name()を呼び出す
-- パラメータ付き、すべて
proc_name(1,2)を呼び出す
-- パラメータはin、out、inoutです
@t1=0 を設定します。
@t2=3 を設定します。
proc_name(1,2,@t1,@t2) を呼び出す

#!/usr/bin/env python
# -*- コーディング:utf-8 -*-
pymysqlをインポートする
conn = pymysql.connect(ホスト='127.0.0.1'、ポート=3306、ユーザー='root'、パスワード='123'、データベース='t1')
カーソル = conn.cursor(cursor=pymysql.cursors.DictCursor)
# ストアドプロシージャを実行します。cursor.callproc('p1', args=(1, 22, 3, 4))
# 実行後にパラメータを取得して保存します cursor.execute("select @_p1_0,@_p1_1,@_p1_2,@_p1_3")
結果 = cursor.fetchall()
conn.commit()
カーソルを閉じる()
接続を閉じる()
印刷(結果)

プロシージャ proc_name を削除します。