Включая параметры в OPENQUERY
Как я могу использовать параметр внутри sql openquery, например:
SELECT * FROM OPENQUERY([NameOfLinkedSERVER], 'SELECT * FROM TABLENAME
where field1=@someParameter') T1 INNER JOIN MYSQLSERVER.DATABASE.DBO.TABLENAME
T2 ON T1.PK = T2.PK
15 ответов
В документации ОТКРЫТИЯ говорится, что:
OPENQUERY не принимает переменные для своих аргументов.
Смотрите эту статью для обхода.
ОБНОВИТЬ:
Как и предполагалось, я включаю рекомендации из статьи ниже.
Передать основные значения
Если базовая инструкция Transact-SQL известна, но вам необходимо передать одно или несколько конкретных значений, используйте код, подобный следующему примеру:
DECLARE @TSQL varchar(8000), @VAR char(2)
SELECT @VAR = 'CA'
SELECT @TSQL = 'SELECT * FROM OPENQUERY(MyLinkedServer,''SELECT * FROM pubs.dbo.authors WHERE state = ''''' + @VAR + ''''''')'
EXEC (@TSQL)
Пройти весь запрос
Когда вам нужно передать весь запрос Transact-SQL или имя связанного сервера (или оба), используйте код, подобный следующему примеру:
DECLARE @OPENQUERY nvarchar(4000), @TSQL nvarchar(4000), @LinkedServer nvarchar(4000)
SET @LinkedServer = 'MyLinkedServer'
SET @OPENQUERY = 'SELECT * FROM OPENQUERY('+ @LinkedServer + ','''
SET @TSQL = 'SELECT au_lname, au_id FROM pubs..authors'')'
EXEC (@OPENQUERY+@TSQL)
Используйте хранимую процедуру Sp_executesql
Чтобы избежать многослойных кавычек, используйте код, подобный следующему примеру:
DECLARE @VAR char(2)
SELECT @VAR = 'CA'
EXEC MyLinkedServer.master.dbo.sp_executesql
N'SELECT * FROM pubs.dbo.authors WHERE state = @state',
N'@state char(2)',
@VAR
Со страницы MSDN:
OPENQUERY не принимает переменные для своих аргументов
По сути, это означает, что вы не можете выполнить динамический запрос. Чтобы добиться того, что пытается сделать ваш образец, попробуйте это:
SELECT * FROM
OPENQUERY([NameOfLinkedSERVER], 'SELECT * FROM TABLENAME') T1
INNER JOIN
MYSQLSERVER.DATABASE.DBO.TABLENAME T2 ON T1.PK = T2.PK
where
T1.field1 = @someParameter
Ясно, что если ваша таблица TABLENAME содержит большой объем данных, она также будет распространяться по сети, и производительность может быть низкой. С другой стороны, для небольшого объема данных это работает хорошо и позволяет избежать динамических накладных расходов на создание sql (внедрение sql, экранирование кавычек), exec подход может потребовать.
Вы можете выполнить строку с OPENQUERY, как только вы ее создадите. Если вы идете этим путем, подумайте о безопасности и постарайтесь не объединять введенный пользователем текст в ваш SQL!
DECLARE @Sql VARCHAR(8000)
SET @Sql = 'SELECT * FROM Tbl WHERE Field1 < ''someVal'' AND Field2 IN '+ @valueList
SET @Sql = 'SELECT * FROM OPENQUERY(SVRNAME, ''' + REPLACE(@Sql, '''', '''''') + ''')'
EXEC(@Sql)
На самом деле, мы нашли способ сделать это:
DECLARE @username varchar(50)
SET @username = 'username'
DECLARE @Output as numeric(18,4)
DECLARE @OpenSelect As nvarchar(500)
SET @OpenSelect = '(SELECT @Output = CAST((CAST(pwdLastSet As bigint) / 864000000000) As numeric(18,4)) FROM OpenQuery (ADSI,''SELECT pwdLastSet
FROM ''''LDAP://domain.net.intra/DC=domain,DC=net,DC=intra''''
WHERE objectClass = ''''User'''' AND sAMAccountName = ''''' + @username + '''''
'') AS tblADSI)'
EXEC sp_executesql @OpenSelect, N'@Output numeric(18,4) out', @Output out
SELECT @Output As Outputs
Это назначит результат выполнения OpenQuery в переменной @Output.
Мы тестировали процедуру Store в MSSQL 2012, но должны работать с MSSQL 2008+.
Microsoft заявляет, что sp_executesql(Transact-SQL): применяется к: SQL Server (SQL Server 2008 до текущей версии), базе данных SQL Azure Windows (от первоначального выпуска до текущего выпуска). ( http://msdn.microsoft.com/en-us/library/ms188001.aspx)
Мы можем использовать execute метод вместо openquery. Его код намного чище. Я должен был получитьlinked serverрезультат запроса в переменной. Я использовал следующий код.
CREATE TABLE #selected_store
(
code VARCHAR(250),
id INT
)
declare @storeId as integer = 25
insert into #selected_store (id, code) execute('SELECT store_id, code from quickstartproductionnew.store where store_id = ?', @storeId) at [MYSQL]
declare @code as varchar(100)
select @code = code from #selected_store
select @code
drop table #selected_store
Заметка:
если ваш запрос не работает, пожалуйста, убедитесь
remote proc transaction promotionустановлен какfalseдля тебяlinked serverподключение.
EXEC master.dbo.sp_serveroption
@server = N'{linked server name}',
@optname = N'remote proc transaction promotion',
@optvalue = N'false';
DECLARE @guid varchar(36); select @guid= convert(varchar(36), NEWID() );
/*
The one caveat to this technique is that ##ContextSpecificGlobal__Temp should ALWAYS have the exact same columns.
So make up your global temp table name in the sproc you're using it in and only there!
In this example I wanted to pass in the name of a global temporary table dynamically. I have 1 procedure dropping
off temporary data in whatever @TableSrc is and another procedure picking it up but we are dynamically passing
in the name of our pickup table as a parameter for OPENQUERY.
*/
IF ( OBJECT_ID('tempdb..##ContextSpecificGlobal__Temp' , 'U') IS NULL )
EXEC ('SELECT * INTO ##ContextSpecificGlobal__Temp FROM OPENQUERY(loopback, ''Select *,''''' + @guid +''''' as tempid FROM ' + @TableSrc + ''')')
ELSE
EXEC ('INSERT ##ContextSpecificGlobal__Temp SELECT * FROM OPENQUERY(loopback, ''Select *,''''' + @guid +''''' as tempid FROM ' + @TableSrc + ''')')
--If this proc is run frequently we could run into race conditions, that's why we are adding a guid and only deleting
--the data we added to ##ContextSpecificGlobal__Temp
SELECT * INTO #TableSrc FROM ##ContextSpecificGlobal__Temp WHERE tempid = @guid
BEGIN TRAN t1
IF ( OBJECT_ID('tempdb..##ContextSpecificGlobal__Temp' , 'U') IS NOT NULL )
BEGIN
-- Here we wipe out our left overs if there if everyones done eating the data
IF (SELECT COUNT(*) FROM ##ContextSpecificGlobal__Temp) = 0
DROP TABLE ##ContextSpecificGlobal__Temp
END
COMMIT TRAN t1
-- YEAH! Now I can use the data from my openquery without wrapping the whole !$#@$@ thing in a string.
Объедините динамический SQL с OpenQuery. (Это идет на сервер Teradata)
DECLARE
@dayOfWk TINYINT = DATEPART(DW, GETDATE()),
@qSQL NVARCHAR(MAX) = '';
SET @qSQL = '
SELECT
*
FROM
OPENQUERY(TERASERVER,''
SELECT DISTINCT
CASE
WHEN ' + CAST(@dayOfWk AS NCHAR(1)) + ' = 2
THEN ''''Monday''''
ELSE ''''Not Monday''''
END
'');';
EXEC sp_executesql @qSQL;
SELECT field1 FROM OPENQUERY
([NameOfLinkedSERVER],
'SELECT field1 FROM TABLENAME')
WHERE field1=@someParameter T1
INNER JOIN MYSQLSERVER.DATABASE.DBO.TABLENAME
T2 ON T1.PK = T2.PK
В следующем примере я передаю параметр отдела в хранимую процедуру (spIncreaseTotalsRpt), и в то же время я создаю временную таблицу из OPENQUERY. Таблица Temp должна быть глобальной Temp (##), чтобы на нее можно было ссылаться за пределами ее intance. Используя exec sp_executesql, вы можете передать параметр отдела.
Примечание: будьте осторожны при использовании sp_executeSQL. Также ваш админ может не иметь этой опции для вас.
Надеюсь, это кому-нибудь поможет.
IF OBJECT_ID('tempdb..##Temp') IS NOT NULL
/*Then it exists*/
begin
DROP TABLE ##Temp
end
Declare @Dept as nvarchar(20) ='''47'''
declare @OPENQUERY as nvarchar(max)
set @OPENQUERY = 'Select ' + @Dept + ' AS Dept, * into ##Temp from openquery(SQL_AWSPROD01,'''
declare @sql nvarchar(max)= @openquery + 'SET FMTONLY OFF EXECUTE SalaryCompensation.dbo.spIncreaseTotalsRpts ' + '''' + @Dept + '''' + ''')'
declare @parmdef nvarchar(25)
DECLARE @param nvarchar(20)
SET @parmdef = N'@Dept varchar(20)'
-- select @sql
-- Print @sql + @parmdef + @dept
exec sp_executesql @sql,@parmdef, @Dept
Select * from ##Temp
Результаты
Увеличение отдела Cnt 0 1 2 3 4 5 6 0,0000 1,0000 0,0000 0,0000 0,0000 0,0000 0,0000 0,0000
SET NOCOUNT ON;
DECLARE @qry NVARCHAR(MAX);
SELECT @qry=concat('select * from openquery(nube,',char(39),'call DATABASE.STORE_PROCEDURE(',@year,',',@month,',',@day,',"',@place,'")',char(39),')');
EXECUTE sp_executesql @qry;
убедитесь, что создайте перед параметрами
DECLARE @usernames NVARCHAR(MAX);
SET @usernames = N'';
DECLARE @len INT;
SELECT @usernames = @usernames + ISNULL(username + ''''',''''', '')
FROM #tempusername;
SET @len = len(@usernames);
SET @usernames = N'''''' + LEFT(@usernames, @len - 3);
DECLARE @sql NVARCHAR(MAX);
SET @sql
= N'SELECT *
FROM OPENQUERY
([Linked Server],
''SELECT username
FROM [MySQL Database].[Table Name]
WHERE username IN ( ' + @usernames + N')'')';
Я нашел этот обходной путь по этой ссылке https://social.technet.microsoft.com/Forums/en-US/98e0c17a-8ead-4633-a053-51c49b313bd3/how-can-i-use-a-table-variable-as-a-parameter-for-openquery?forum=sqltools&amp;prof=required это было очень полезно.
Я выяснил способ, который работает для меня. Тем не менее, требуется использовать чистую таблицу, к которой у связанного сервера есть доступ.
Я создал таблицу и заполнил ее необходимыми значениями, после чего я ссылаюсь на эту таблицу через связанный сервер.
SELECT *
FROM OPENQUERY(KHSSQLODSPRD,'SELECT *
FROM ABC.dbo.CLAIM A WITH (NOLOCK)
WHERE A.DOS >= (SELECT MAX(DATE) FROM KHSDASQL01.DA_MAIN.[dbo].[ALLFILENAMES]) ')
declare @p_Id varchar(10)
SET @p_Id = '40381'
EXECUTE ('BEGIN update TableName
set ColumnName1 = null,
ColumnName2 = null,
ColumnName3 = null,
ColumnName4 = null
where PERSONID = '+ @p_Id +'; END;') AT [linked_Server_Name]
Просто попробуйте так, должно работать, легко! В предложении WHERE после имени столбца и знака равенства:- добавьте ДВЕ одинарные кавычки, значение поиска, а затем ТРИ одинарные кавычки. Закройте скобу.
SELECT * FROM OPENQUERY([NameOfLinkedSERVER], 'SELECT * FROM TABLENAME where field1=''your search value''') T1 INNER JOIN MYSQLSERVER.DATABASE.DBO.TABLENAME T2 ON T1.PK = T2.PK
Простой пример, основанный на приведенном выше примере @Tuan Zaidi, который казался самым простым. Не знал, что вы можете сделать фильтр снаружи OPENQUERY... намного проще!
Однако в моем случае мне нужно было поместить его в переменную, поэтому я создал дополнительный уровень подзапроса, чтобы вернуть одно значение.
SET @SFID = (SELECT T.Id FROM (SELECT Id, Contact_ID_SQL__c FROM OPENQUERY([TR-SF-PROD], 'SELECT Id, Contact_ID_SQL__c FROM Contact') WHERE Contact_ID_SQL__c = @ContactID) T)