python調用sql
『壹』 python 如何使用源生sql語句查詢多個參數的情況
#coding:utf-8
#anexample
"""
--theSQLServerstorageprocess:
dropprocereproc_getconflist
go
createprocereproc_getconflist
@customerchar(6)
,@servicekeyvarchar(16)=NULL
,@dt_bgndatetime=NULL
,@dt_enddatetime=NULL
asbegin
selectbillsumidxasidx
fromconf_billsum
where1=1
andsumtypeid=1
andisnull(@customer,customercode)=customercode
andisnull(@servicekey,servicekey)=servicekey
andisnull(@dt_bgn,begintime)<endtime
andbegintime<isnull(@dt_end,endtime)
end
go
"""
importpymssql
conn=pymssql.connect(
host="192.168.70.7",
user='pyquery',
password='Qpery',
database='gb201412',
)
curr=conn.cursor()
curr.execute("execproc_getconflist%s,%s,%s,%s",
('990003',None,None,None))
foridx,incurr:
printidx
curr.close()
conn.close()
『貳』 如何使用python對資料庫進行操作
你可以訪問Python資料庫介面及API查看詳細的支持資料庫列表。不同的資料庫你需要下載不同的DB API模塊，例如你需要訪問Oracle資料庫和Mysql數據，你需要下載Oracle和MySQL資料庫模塊。
DB-API 是一個規范. 它定義了一系列必須的對象和資料庫存取方式, 以便為各種各樣的底層資料庫系統和多種多樣的資料庫介面程序提供一致的訪問介面 。
Python的DB-API，為大多數的資料庫實現了介面，使用它連接各資料庫後，就可以用相同的方式操作各資料庫。
Python DB-API使用流程：
引入 API 模塊。
獲取與資料庫的連接。
執行SQL語句和存儲過程。
關閉資料庫連接。
什麼是MySQLdb?
MySQLdb 是用於Python鏈接Mysql資料庫的介面，它實現了 Python 資料庫 API 規范 V2.0，基於 MySQL C API 上建立的。
如何安裝MySQLdb?
為了用DB-API編寫MySQL腳本，必須確保已經安裝了MySQL。復制以下代碼，並執行：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
如果執行後的輸出結果如下所示，意味著你沒有安裝 MySQLdb 模塊：
Traceback (most recent call last):
File "test.py", line 3, in <mole>
import MySQLdb
ImportError: No mole named MySQLdb
『叄』 Python接入不同類型資料庫的通用介面方法
日常數據管理工作中，需要處理存儲在不同類型資料庫系統的數據。對這些數據的管理，常見的是使用Navicat,DBeaver等管理工具。在對大量數據分析時，需要提取到Python/R中進行處理。下面 探索 Python調用MySQL,MongoDB,InfluxDB等多種類型資料庫通用連接方法。實現方式是在Python中封裝各類資料庫介麵包。
實現後的效果：1.安全。介面信息封裝便於保密管理；2.復用。一次封裝，永久復用；3.上手快。方便不熟悉python和數據調用的同學，只會簡單的sql即可使用，省時省力。
下面以MySQL,MongoDB,InfluxDB為例定義介面方法，然後把它們封裝成1個通用方法。
mysql_get(sql,db):
mongo_get(sql,db):
influx_get(sql,db):
可以看到，以上函數共同調用的參數為sql和db。我們再增加一個參數db_type，將構造一個通用的方法對以上資料庫調用。
同理，其他類型的資料庫也可以加入到這個通用框架中，包括但不限於各類關系型，鍵值型，時序型資料庫。
『肆』 怎麼用python導入SQL
訪問MYSQL的話使用，MySQLdb模塊
import os,sys
import MySQLdb
try:
conn=MySQLdb.connect(host='localhost',user='root',passwd="",db='YOURDB')
except Exception,e:
print e
sys.exit()
cursor=conn.cursor()
sql="insert into address(name,address) values (%s,%s)"
values=(("zhang","being"),("li","beijing"),("wang","beijing"))
try:
cursor.executemany(sql,values)#插入數條數據
except Exception , e:
print e
sql="select * from address"
cursor.execute(sql) #查詢
data=cursor.fetchall()
if data:
for x in data:
print x[0],x[1]
cursor.close()#關閉游標
conn.close()#關閉資料庫