⑴ python 怎麼調用odbc
入門
連接到資料庫
調用connect方法並傳入ODBC連接字元串,其會返回一個connect對象。通過connect對象,調用cursor()方法,可以獲取一個游標cursor。如下代碼示例:
import pyodbc
#連接示例: Windows系統, 非DSN方式, 使用微軟 SQL Server 資料庫驅動
cnxn =pyodbc.connect('DRIVER={SQL Server};SERVER=localhost;PORT=1433;DATABASE=testdb;UID=me;PWD=pass')
#連接示例: linux系統, 非DSN方式, 使用FreeTDS驅動
cnxn =pyodbc.connect('DRIVER={FreeTDS};SERVER=localhost;PORT=1433;DATABASE=testdb;UID=me;PWD=pass;TDS_Version=7.0')
#連接示例:使用DSN方式
cnxn = pyodbc.connect('DSN=test;PWD=password')
# 打開游標
cursor =cnxn.cursor()
以上示例只是標准示例,具體的ODBC連接字元串以你自己使用的驅動為准。
查詢一些數據
所有SQL語句都使用Cursor.execute()方法執行。比如select語句會返回一些結果行,你可以使用游標(Cursor)相關的函數功能(fetchone,fetchall,fetchmany)對結果進行檢索。
Cursor.fetchone 用於返回一個單行( Row)對象:
cursor.execute("selectuser_id, user_name from users")
row =cursor.fetchone()
if row:
print(row)
Row 對象是類似一個python元組(tuples),不過也可以通過列名稱來訪問,例如:
cursor.execute("selectuser_id, user_name from users")
row =cursor.fetchone()
print('name:',row[1]) # 使用列索引號來訪問數據
print('name:',row.user_name) # 或者直接使用列名來訪問數據
當所有行都已被檢索,則fetchone返回None.
while 1:
row = cursor.fetchone()
if not row:
break
print('id:', row.user_id)
Cursor.fetchall方法返回所有剩餘行並存儲於一個列表中。如果沒有行,則返回一個空列表。(注意:如果有很多行,會造成大量內存佔用。Fetchall會一次性將所有數據查詢到本地,然後再遍歷)
cursor.execute("selectuser_id, user_name from users")
rows = cursor.fetchall()
for row in rows:
print(row.user_id, row.user_name)
如果並不在意數據處理時間,可以使用游標本身作為一個迭代器,逐行迭代。這樣可以節省大量的內存開銷,但是由於和數據來回進行通信,速度會相對較慢:
cursor.execute("selectuser_id, user_name from users"):
for row in cursor:
print(row.user_id, row.user_name)
由於Cursor.execute總是返回遊標(cursor), 所以也可以簡寫成:
for row incursor.execute("select user_id, user_name from users"):
print(row.user_id, row.user_name)
我們可以在execut中使用」」」三重引號,來應用多行SQL字元串。這樣sql的可讀性大大增強。這是python特有的特性:
cursor.execute(
"""
select user_id, user_name
from users
where last_logon < '2001-01-01'
and bill_overe = 1
""")
SQL參數
ODBC支持使用問號作為SQL的查詢參數佔位符。可以在execute方法的SQL參數之後,提供SQL參數佔位符的值:
cursor.execute(
"""
select user_id, user_name
from users
where last_logon < ?
and bill_overe = ?
""", '2001-01-01', 1)
這樣做可以防止SQL注入攻擊,提高安全性。如果使用不同的參數反復執行相同的SQL它效率會更高,這種情況下該SQL將只預裝(prepared )一次。(pyodbc只保留最後一條編寫的語句,所以如果程序在語句之間進行切換,每次都會預裝,造成多次預裝。)
Python的DB API指定參數應以序列(sequence)對象傳遞,所以pyodbc也支持這種方式:
cursor.execute(
"""
select user_id, user_name
from users
where last_logon < ?
and bill_overe = ?
""", ['2001-01-01', 1])
插入數據
插入數據使用相同的函數 - 通過傳入insert SQL和相關佔位參數執行插入數據:
cursor.execute("insertinto procts(id, name) values ('pyodbc', 'awesome library')")
cnxn.commit()
cursor.execute("insertinto procts(id, name) values (?, ?)", 'pyodbc', 'awesome library')
cnxn.commit()
注意:調用cnxn.commit()。發成錯誤可以回滾。具體需要看資料庫特性支持情況。如果數據發生改變,最好進行commit。如果不提交,則在連接中斷時,所有數據會發生回滾。
更新和刪除數據
更新和刪除工作以同樣的方式:通過特定的SQL來執行。通常我們都想知道更新和刪除的時候有多少條記錄受到影響,可以使用Cursor.rowcount來獲取值:
cursor.execute("deletefrom procts where id <> ?", 'pyodbc')
print('Deleted {}inferior procts'.format(cursor.rowcount))
cnxn.commit()
由於execute 總是返回遊標(允許你調用鏈或迭代器使用),有時我們直接這樣簡寫:
deleted =cursor.execute("delete from procts where id <> 'pyodbc'").rowcount
cnxn.commit()
注意一定要調用commit。否則連接中斷時會造成改動回滾。
技巧和竅門
引號
於單引號SQL是有效的,當值需要使用單引號時,使用用雙引號包圍的SQL:
cursor.execute("deletefrom procts where id <> 'pyodbc'")
如果使用三重引號, 我們可以這樣使用單引號:
cursor.execute(
"""
delete
from procts
where id <> 'pyodbc'
""")
列名稱
Microsoft SQLServer之類的一些資料庫不會產生計算列的列名,在這種情況下,需要通過索引來訪問列。我們也可以使用sql列別名的方式,為計算列指定引用名稱:
row =cursor.execute("select count(*) as user_count fromusers").fetchone()
print('{}users'.format(row.user_count)
當然也可以直接使用列索引來訪問列值:
count =cursor.execute("select count(*) from users").fetchone()[0]
print('{}users'.format(count)
注意,上例的首列不能是Null。否則fetchone方法將返回None並且會報NoneType不支持索引的錯誤。如果有一個默認值,經常可以是ISNULL或合並:
maxid =cursor.execute("select coalesce(max(id), 0) fromusers").fetchone()[0]
自動清理
連接(默認)在一個事務中。如果一個連接關閉前沒有提交,則會進行當前事務回滾。很少需要finally或except 語句來執行人為的清理操作,程序會自動清理。
例如,如果下列執行過程中任何一條SQL語句出現異常,都將引發導致這兩個游標執行失效。從而保證原子性,要麼所有數據都插入發生,要麼所有數據都不插入。不需要人為編寫清理代碼。
cnxn =pyodbc.connect(...)
cursor = cnxn.cursor()
cursor.execute("insertinto t(col) values (1)")
cursor.execute("insertinto t(col) values (2)")
cnxn.commit()
⑵ python連接sqlserver資料庫問題
conn=pymssql.connect(host='.',database='wincc')
conn=pymssql.connect(host='.',database='sqlex')
這樣連接不上嗎?希望能提供更多信息。
⑶ python連接sqlserver資料庫報錯,是什麼原因
這個是靜態分析時 沒匹配到這個成員方法
至於運行時 有沒有這個方法 可以用 print dir(conn)看下 應該是有的
⑷ python連不上sqlserver
pymssql.connect(host='127.0.0.1',user='sa',password='sa',database='PSKJC',tds_version='7.1')
你的連接代碼換成我這個看看,前提是你的sqserver已經啟動了
⑸ 怎麼用python向sqlserver中導入數據
import pymssql
conn = pymssql.connect(..)
curr = conn.cursor()
curr.executemany("insert into thetable values (%s, %s)", result)
conn.commit()
curr.close()
conn.close()
⑹ python連接sqlserver哪個性能好
解決辦法
到伺服器中
1.確定資料庫的登錄用戶名與密碼是否正確
2.配置sqlserver支持遠程連接
參考鏈接:
【1】SQL Server 2008 R2如何開啟資料庫的遠程連接
【2】當使用第一個鏈接配置時,我遇到「sqlserver browser 無法啟動的錯誤」。解決辦法:進入服務管理器,找到 SQL SERVER BROWER右擊屬性打開,啟動模式為 手動或者自動,再啟用SQL SERVER BROWER服務。
⑺ python怎樣實現sqlserver備份
用python是非常方便的,非常方便就能備份mysql和sqlserver,
下面我們來具體看看如何用:
#coding=gbk
import os
import time
os.system("mysqlmp -h192.168.0.2 -uddd -pggg xdreams >E:/mysqldack/xdreams/xdreamsfdfdf.txt")
上面就成功把0.2機器上的mysql資料庫備份下來,
導入資料庫:mysql -h192.168.0.2 -uroot -psz212 -P 7659 hotelguanli < G:/temp/2013-03-28-10-34-35.sql
下面是sqlserver的:
os.system("sqlcmd.exe -S 127.0.0.1,56678 -U sa -P 123456 -d 資料庫名 -b -c cmd_end -Q \"backup database 資料庫名 to disk='d:/sql.bak'\"")
看看,是不是很簡單。
當然還可以通過os.path.getsize(r"d:/sql.bak")/1024來獲取這個文件的大小,返回的是K,
備份文件還可以用時間值來命名:
如:
nowtime=time.strftime('%Y-%m-%d-%H-%M-%S',time.localtime(time.time()))+""
改造上面一條:
os.system("mysqlmp -h192.168.0.2 -uddd -pggg xdreams >E:/mysqldack/xdreams/xdreams"+nowtime+".txt")
如果再完善一點,就加個備份完成後發一封郵件到你郵箱里吧。
其它要注意到的一點就是sqlxerver和備份中,sqlserver伺服器實列要支付遠程連接,開啟sql brower服務
兩個資料庫的密碼不要含有"^"這個符號,因為在cmd里好像識別不到它,轉義也不行,具體原因沒查到.
現在,加在windows或linux的計劃任務中去,每天執行它,至此,大功告成.
⑻ sqlserver 能通過作業調用外部程序嗎(如.exe)
EXEC master..xp_cmdshell 'notepad.exe'
⑼ python 如何執行復雜sqlserver語句
很簡單
將以上語句封裝為存儲過程
再使用python調用即可
⑽ python怎麼樣使用Windows身份驗證模式登錄sqlserver資料庫。只能是代碼實現。求python大佬解答。
做不到的,讓管理員設置一個普通用戶,許可權只能管理一個或幾個資料庫的增,刪,查就可以了。別折騰些沒有用的。