本文介紹了使用SqlAlChemy執行原始查詢(針對SQL-Server數據庫和Pymssql)時,傳遞無法識別的參數并引發SQL錯誤的處理方法,對大家解決問題具有一定的參考價值,需要的朋友們下面隨著小編來一起學習吧!
問題描述
我正在嘗試使用SqlAlChemy(將Pymssql作為提供程序)在SQL-Server數據庫上執行簡單的原始SQL查詢。
這是我的第一次嘗試(使用execute
連接方法并以**kwargs方式傳遞參數):
provider = DataProvider().engine
q = "select url from Crawler.CrawlSource where source=@source"
query = text(q)
result = provider.connect().execute(query, source ='mysource')
我以教程中所示的任何方式傳遞參數(作為kwargs傳遞和作為dict傳遞),但它們都不起作用,并且當調用execute
方法時拋出異常,該異常顯示'Must declare the scalar variable' @source
好像沒有參數傳遞給execute
方法,看起來ORM(或者可能是數據提供程序(本例中為pymssql))不識別傳遞給execute
方法的參數,只傳遞query(
我猜MSSQL-Server提供程序(Pymssql)可能有問題,因為SQL-Server在SqlAlChemy和Python家族中不是一等公民,但沒有直接線索導致此問題。
如上所述,我還嘗試了其他方法
這是我的第二次嘗試(使用execute
連接方法并將參數作為dict傳遞):
provider = DataProvider().engine
q = "select url from Crawler.CrawlSource where source=@source"
query = text(q)
result = provider.connect().execute(query, {source :'mysource'})
我的第三次嘗試(使用Engine對象的execute
方法,以**kwargs方式傳遞參數):
provider = DataProvider().engine
q = "select url from Crawler.CrawlSource where source=@source"
query = text(q)
result = provider.execute(query, source ='mysource')
我的第四次嘗試(使用Engine對象的execute
方法,參數作為dict傳遞):
provider = DataProvider().engine
q = "select url from Crawler.CrawlSource where source=@source"
query = text(q)
result = provider.execute(query, {source :'mysource'})
我的第五次嘗試(創建Session并使用Session的execute
方法,將參數作為dict傳遞):
provider = DataProvider().engine
session = sessionmaker(bind=provider)()
q = "select url from Crawler.CrawlSource where source=@source"
query = text(q)
result = session.execute(query, {source :'mysource'})
我的第六次嘗試(創建Session,使用Session的execute
方法,以**kwargs方式傳遞參數):
provider = DataProvider().engine
session = sessionmaker(bind=provider)()
q = "select url from Crawler.CrawlSource where source=@source"
query = text(q)
result = session.execute(query, source='mysource')
但正如我前面提到的,上述努力都沒有奏效,它們都導致了上面提到的相同異常
如有任何幫助,我們將不勝感激
推薦答案
mssql+pymssql方言似乎支持";pyformat";paramstyle。這對我有效:
import sqlalchemy as sa
engine = sa.create_engine("mssql+pymssql://@localhost:49242/myDb")
sql = "SELECT word FROM vocabulary WHERE language = %(lang)s"
params = {'lang': 'Greek'}
with engine.begin() as conn:
result = conn.execute(sql, params).fetchall()
print(result)
# [('γιορτ?',), ('ηλεκτρονικ?? υπολογιστ??',)]
如果使用SQLAlChemytext
對象,還可以使用名為";的參數樣式:
sql = sa.sql.text("SELECT word FROM vocabulary WHERE language = :lang")
params = {'lang': 'Greek'}
with engine.begin() as conn:
result = conn.execute(sql, params).fetchall()
print(result)
# [('γιορτ?',), ('ηλεκτρονικ?? υπολογιστ??',)]
text
對象允許我們一致使用名為";的參數樣式,而不考慮DB-API層支持的本機參數樣式(例如,%s
用于pymssql,?
用于pyodbc)。
這篇關于使用SqlAlChemy執行原始查詢(針對SQL-Server數據庫和Pymssql)時,傳遞無法識別的參數并引發SQL錯誤的文章就介紹到這了,希望我們推薦的答案對大家有所幫助,