程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 數據庫知識 >> MYSQL數據庫 >> MySQL綜合教程 >> Python如何對MySQL存儲過程進行調用?

Python如何對MySQL存儲過程進行調用?

編輯:MySQL綜合教程

此文章主要向大家描述的是Python對MySQL存儲過程進行調用的正確操作步驟,以及在其實際操作中值得我們大家注意的事項的描述,你如果對其有興趣的話你就可以點擊以下的文章進行觀看了。

環境:

1.MySQL5.0 或者以上支持MySQL存儲過程的版本

2.安裝MySQL-python,目前支持到2.x

步驟:

一.數據庫准備

1.建立表

  1. view sourceprint?1 CREATE TABLE `Account` (   
  2. `id` BIGINT(20) NOT NULL AUTO_INCREMENT,   
  3. `sm_accountName` VARCHAR(100) COLLATE gbk_chinese_ci NOT NULL DEFAULT '',   
  4. `sm_password` TEXT COLLATE gbk_chinese_ci NOT NULL,   
  5. `sm_onlineTime` BIGINT(20) UNSIGNED NOT NULL DEFAULT '0',   
  6. PRIMARY KEY (`id`),   
  7. UNIQUE KEY `accountNameIndex` (`sm_accountName`)   
  8. )ENGINE=InnoDB   

2.建立MySQL存儲過程

  1. view sourceprint?01 CREATE PROCEDURE `proctest`(IN i_id BIGINT, IN i_onlinetime BIGINT, OUT o_accname VARCHAR(30), OUT o_accpwd VARCHAR(50))   
  2. 02 NOT DETERMINISTIC   
  3. 03 CONTAINS SQL   
  4. 04 SQL SECURITY DEFINER   
  5. 05 COMMENT ''   
  6. 06 BEGIN   
  7. 07 select sm_accountName,sm_password   
  8. 08 into o_accname,o_accpwd   
  9. 09 from `tbl_Account` where id=i_id and sm_onlineTime=i_onlinetime limit 1;   
  10. 10 END;   

3.插入部分數據

  1. view sourceprint?1 INSERT INTO `Account` (`id`, `sm_accountName`, `sm_password`, `sm_onlineTime`) VALUES   
  2. 2 (1, 'luoshulin', 'asdfsdf', 0),   
  3. 3 (2, 'test', '1', 0),   
  4. 4 (3, 'adsfasd', 'asdf', 1);   

到這裡數據庫相關內容就准備好了接下去開始寫python腳本

二.python腳本

  1. view sourceprint?01 #!/usr/bin/env python   
  2. 02 # -*- coding: utf8 -*-   
  3. 03 import MySQLdb   
  4. 04 import time   
  5. 05 import os, sys, string   
  6. 06 def CallProc(id,onlinetime):   

07 '''調用MySQL存儲過程,

08 輸入參數:編號,在線時間,輸出:帳號,密碼;

09 使用輸出參數方式'''

10 accname=''

11 accpwd=''

12 conn = MySQLdb.connect(host='localhost',user='root',passwd='111111',db='ceshi')

13 cur =conn.cursor()

14 cur.callproc('proctest',(id,onlinetime,accname,accpwd))

15 cur.execute('select @_proctest_2,@_proctest_3')

16 data=cur.fetchall()

17 if data:

18 for rec in data:

19 accname=rec[0]

20 accpwd=rec[1]

21 cur.close()

22 conn.close();

23 return accname,accpwd

24 def CallProct(id,onlinetime):

25 '''調用MySQL存儲過程,

26 輸入參數:編號,在線時間,輸出:帳號,密碼;

27 使用select返回記錄方式'''

28 accname=''

29 accpwd=''

30 conn = MySQLdb.connect(host='localhost',user='root',passwd='111111',db='ceshi')

31 cur =conn.cursor()

32 cur.nextset()

33 cur.execute('call ptest(%s,%s)',(id,onlinetime))

34 data=cur.fetchall()

35 if data:

36 for rec in data:

37 accname=rec[0]

38 accpwd=rec[1]

39 cur.close()

40 conn.close();

41 return accname,accpwd

42 name,pwd=CallProct(1,0)

43 print name,pwd

三.測試

將python腳本保存為 並執行可以看到結果

view sourceprint?1 [root@redhat-dev python]# python pycallproc.py

2 luoshulin asdfsdf

測試使用的是select返回記錄的方式,對於使用輸出參數返回結果情況也是一樣的。

以上的相關內容就是對python調用MySQL存儲過程的介紹,望你能有所收獲。

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved