pgsql 外表的坑


项目中需要查询 SQL Server(老系统) 和 pgsql 中的数据,索性就将 SQL Server 的表作为外表在 pgsql 中创建:

-- 使用 tds_fdw 扩展插件创建一个外部数据库连接服务
CREATE SERVER mssql_svr FOREIGN DATA WRAPPER tds_fdw OPTIONS (servername '192.168.1.37', port '1433', character_set 'UTF-8', database 'sql_server');

-- 为本地数据库用户 postgres 在外部数据库连接服务 mssql_svr 上创建用户映射,对应了远程数据库的 sa 用户
CREATE USER MAPPING FOR postgres SERVER mssql_svr OPTIONS (username 'sa', password 'sql2008});

-- 创建外表
CREATE FOREIGN TABLE warranty_promotion."organization" (
    id          char(36)           NOT NULL,
    org_name    varchar(100)       NOT NULL,
    org_code    varchar(20)        NOT NULL,
    manager_id  char(36)           NOT NULL,
) SERVER mssql_svr OPTIONS (table 'org');

CREATE FOREIGN TABLE pgsql.user (
    id           varchar(50) OPTIONS (column_name 'ID'),
    user_name    varchar(50)  OPTIONS (column_name 'Username'),
    email        varchar(200) OPTIONS (column_name 'Email')
) SERVER mssql_svr OPTIONS (table 'user');

在进行外表的关联查询时,经常会报错:

### The error may exist in file [D:/Source/***-persistence/target/classes/mybatis/mapper/OrganizationDao.xml]
### The error may involve defaultParameterMap
### The error occurred while setting parameters
### SQL: SELECT t1.id, t1.org_name, t2.email as managerEmail FROM pgsql.organization t1 JOIN pgsql.user t2 ON t1.manager_id = t2.id WHERE t1.org_code IN ( ? )
### Cause: org.postgresql.util.PSQLException: ERROR: DB-Library error: DB #: 20018, DB Msg: General SQL Server error: Check messages from the SQL Server, OS #: -1, OS Msg: , Level: 16
; uncategorized SQLException; SQL state [HV00L]; error code [0]; ERROR: DB-Library error: DB #: 20018, DB Msg: General SQL Server error: Check messages from the SQL Server, OS #: -1, OS Msg: , Level: 16; nested exception is org.postgresql.util.PSQLException: ERROR: DB-Library error: DB #: 20018, DB Msg: General SQL Server error: Check messages from the SQL Server, OS #: -1, OS Msg: , Level: 16
	at org.mybatis.spring.MyBatisExceptionTranslator.translateExceptionIfPossible(MyBatisExceptionTranslator.java:92)

一种解决方法是,如果查询到了结果,缓存到本地,可以尽量避免报错。

另一种解决方法是使用多数据源,不会出现这种奇怪的问题,推荐使用

原创文章,作者:254126420,如若转载,请注明出处:https://blog.ytso.com/tech/database/267449.html

(0)
上一篇 2022年6月15日 07:37
下一篇 2022年6月15日 07:38

相关推荐

发表回复

登录后才能评论