使用SqlAlchemy执行原始查询（在SQLServer数据库和Pymssql上）时，传递未识别的参数并引发SQL错误

Question

我正在尝试使用SqlAlchemy（Pymssql作为提供程序）在sqlserverdb上执行简单的原始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方法的参数，只将查询（没有参数）传递给db engine（这会导致异常）。你知道吗

我猜MSSQL服务器提供程序（Pymssql）可能有一些问题，因为SQLServer不是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'})

我的第五次尝试（创建会话并使用会话的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'})

我的第六次尝试（创建会话并使用会话的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')

但正如我前面提到的，所有这些努力都没有奏效，都导致了上述同样的例外

任何帮助都将不胜感激

Answer 1

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'}
result = engine.execute(sql, params).fetchall()
print(result)
# [('γιορτή',), ('ηλεκτρονικός υπολογιστής',)]

如果使用SQLAlchemytext对象，也可以使用“named”paramstyle：

sql = sa.sql.text("SELECT word FROM vocabulary WHERE language = :lang")
params = {'lang': 'Greek'}
result = engine.execute(sql, params).fetchall()
print(result)
# [('γιορτή',), ('ηλεκτρονικός υπολογιστής',)]

text对象允许我们一致地使用“named”paramstyle，而不考虑DB-API层支持的本机paramstyle（例如，%s对于pymssql，?对于pyodbc）。你知道吗