sql—如何将本地mssql查询的结果传递到链接mysql数据库的查询字符串中

isr3a4wc  于 2021-06-18  发布在  Mysql
关注(0)|答案(1)|浏览(392)

背景:
我正在做一个基于远程mysql(v8)数据库内容生成文档的项目。为了实现这一点,该程序使用了一个本地mssql(2017)数据库,并链接到远程mysql数据库。
问题:
我需要根据mssql查询的内容更新mysql数据库,如下所示:

EXEC('UPDATE LinkedMySQLDB.TableToUpdate AS a SET a.MySQLField=''updated'' WHERE a.ID IN (LocalMSSQLDB.LocalTable.ID) ;') AT LinkedMySQLServer

但是,每次我尝试此操作时,它都会抛出一个错误:

(LocalMSSQLDB.LocalTable.ID)

问题:
有没有办法将本地查询的结果传递到远程数据库的查询字符串中?
或者,是否有不同的方法被推荐?
提前谢谢。

ewm0tg9j

ewm0tg9j1#

您正在尝试访问mysql服务器上的localmssqldb.localtable.id的值。这是不可能的。
可以使用变量来计算语句。在下面的示例中,我为数据库和字段使用了一些其他名称。但是你应该知道大概的意思。通过使用concat,我将文本部分与子查询的结果结合起来,子查询使用string\ u agg转换为逗号分隔的列表。

declare @strSQL varchar(200);
select @strSQL=concat('UPDATE test.test set text=''updated'' WHERE ID in (',(SELECT STRING_AGG(ID, N', ') FROM [SQLTest].dbo.tblTest),');');
EXEC(@strSQL) AT MYSQL2;

这部分 (SELECT STRING_AGG(ID, N', ') FROM [SQLTest].dbo.tblTest) 返回字符串。如果本地表包含id的1和2,结果将是 1, 2 . 与连接 'UPDATE test.test set text=''updated'' WHERE ID in (' 以及 ');' 最终结果将是:

UPDATE test.test set text='updated' WHERE ID in (1, 2);

当它被发送到名为mysql2的mysql服务器时,您将得到所需的结果。
在您的服务器上,它类似于:

declare @strSQL varchar(200);
select @strSQL=concat('LinkedMySQLDB.TableToUpdate AS a SET a.MySQLField=''updated'' WHERE ID in (',(SELECT STRING_AGG(ID, N', ') FROM LocalMSSQLDB..LocalTable),');');
EXEC(@strSQL) AT LinkedMySQLServer;

一定要为@strsql中的所有id腾出空间。200个字符可能不够。

相关问题