本章节为使用者提供最简单的统一SQL的快速入门。

2.1. 在线验证

可以通过 统一SQL在线转换 来快速验证当前统一SQL已支持的功能。

2.2. 集成LightDB-Studio验证

LightDB-Studio是一款数据库客户端工具，详细介绍可参考 LightDB Studio 参考手册 ，目前LightDB-Studio已经支持集成统一SQL，集成之后用户可以直接在LightDB-Studio中编写和执行SQL语句,LightDB-Studio会根据你配置的统一SQL信息将SQL语法转换为目标数据库语句并在目标库执行，用户可以看到转换后的SQL语法及目标端执行结果。下面会按照 集成统一SQL， 创建统一SQL数据源， 验证 依次介绍如何使用LightDB-Studio集成统一SQL并验证。

2.2.1. 集成统一SQL

1. 首先 点击下载 最新版的 LightDB-Studio 客户端工具到本地。

2. 创建 统一SQL驱动管理器 ，用于管理统一SQL自有驱动及目标端数据库所依赖的驱动信息。打开LightDB-Studio，点击菜单栏 数据库 -> 驱动管理器 -> 新建 ，配置 统一SQL驱动管理器 信息。

内容填写参考表格：

填写项	说明
驱动名称	用户自定义，例如：UNISQL
驱动类型	选择Generic
类名	填写：com.hundsun.lightdb.unisql.proxy.Driver
URL模版	不同转换数据源模版配置有所差异，具体可查看 数据源支持范围 表格中 驱动URL模版参考
默认端口	操作目标端数据库端口号，非必填项，默认端口号可根据实际情况填写。
默认数据库	操作目标端数据库名称，非必填项，默认数据库名称可根据实际情况填写。
默认用户名	操作目标端数据库用户名，非必填项，默认用户名可根据实际情况填写。

其他填写项按默认值即可。

例如，添加oracle->DM 数据库的驱动管理器：

3. 点击 库 ，添加 统一SQL依赖驱动包 及 目标端数据库驱动包 ，其中 目标端数据库驱动包 根据实际操作的目标数据库选择添加，添加方式与统一SQL依赖驱动包添加方式一致。点击 添加文件 或 添加文件夹 按钮，选择 sql-convert-runtime-x.x.x.jar 文件，点击 OK 按钮完成添加。依赖包文件可在 统一SQL下载页面 中 LightDB中间件 -> 统一SQL -> 下载(动态库) 下载，下载之后完成解压，找到 sql-convert-runtime-x.x.x.jar 文件。

例如，添加统一SQL依赖及DM数据库驱动依赖：

4. LightDB-Studio 配置统一SQL动态库。

   1. 将下载的 统一SQL依赖包 中的 config 文件夹拷贝到本地lightdb-studio安装目录下。

   2. 将下载的 统一SQL依赖包 中的 动态库文件 拷贝到LightDB-Studio安装目录下的 config 文件夹中，如果是windows系统，动态库可以在 统一SQL下载页面 中 的 LightDB中间件 -> 统一SQL -> windows版(仅用于开发) 下载。

   3. 打开LightDB-Studio安装目录下的 config/unisql.conf 文件，配置 unisql.lib.full-path 项，值为 动态库 所在绝对路径(此配置方法适用于统一SQL大于等于24.2.6版本)， 其他配置项可以参考: unisql.conf文件说明。

   例如：

   

2.2.2. 创建统一SQL数据源

1. 点击LightDB-Studio菜单栏 新建数据库连接

2. 选择刚刚创建的 数据库驱动管理器

例如：

3. 填写目标数据库信息，包括IP地址、端口号、数据库名称、用户名、密码等。可以点击 测试连接 按钮测试连接是否成功。点击 finish 完成配置。

例如：

2.2.3. 验证

选中上一步创建的数据库，右击选择 SQL编辑器 -> 新建SQL编辑器 ，输入源端SQL语法语句并执行。此时操作的SQL语句会经过统一SQL转换为目标端语法并在目标端数据库中执行。

2.3. 支持技术栈

1. 统一SQL当前支持集成在Java技术栈和C技术栈中使用

2.4. 快速集成

1. 在LightDB官网下载统一SQL 下载

2. 基于Java开发时，开发环境需要具备 Java 8 或更高版本的 JDK。

3. 确定源库方言和目标库方言在统一SQL支持范围内。

4. 统一SQL自身依赖的自定义函数需要提前在目标库中完成创建。

5. 统一SQL代理维护在公司仓库中，需要提前联系统一SQL产品组配置仓库地址。

6. 请确保引入最新的 sql-convert-runtime 和 sql-convert-runtime-native 版本，否则可能存在兼容性或引入失败问题。最新版本可查看 版本发布 24.2.6

7. 对于统一SQL Windows 版 SDK，其版本号必须和 sql-convert-runtime 版本号匹配，否则会启动失败。

统一SQL代理是标准的Maven依赖，直接通过 pom.xml 配置即可。C技术栈集成时无需此步骤。

<dependency>
    <groupId>com.hundsun.lightdb</groupId>
    <artifactId>sql-convert-runtime</artifactId>
    <version>24.2.5</version>
</dependency>

2.4.1. Linux系统集成

Linux版统一SQL SDK是标准的Maven依赖，直接通过 pom.xml 配置即可。

<dependency>
    <groupId>com.hundsun.lightdb</groupId>
    <artifactId>sql-convert-runtime-native</artifactId>
    <version>24.2.5</version>
</dependency>

也可以通过 unisql.conf 配置文件中的 unisql.lib.full-path=/xxx/xxx/unisql.linux.x86_64.so 来指定统一SQL SDK所在绝对路径。 或者 unisql.lib.dir=/path/to/ 来指定统一SQL SDK所在目录。（动态库寻找优先级：unisql.lib.full-path > Maven 依赖 > unisql.lib.dir）具体使用方法可参考 配置文件 。

2.4.2. Windows系统集成

1. 获取统一SQL Windows版SDK

2. Java程序启动时，通过 unisql.conf配置文件中的 unisql.lib.full-path=/path/to/unisql.windows.dll 的方式进行集成。具体使用方法可参考 配置文件 。

2.4.3. C技术栈集成

1. 将统一SQL SDK存放至系统能加载的链接库路径下

2. 或者通过unisql.conf配置文件中的 unisql.lib.full-path=/path/to/unisql.xxx.x86_64.so 来指定统一SQL SDK所在路径。具体使用方法可参考 配置文件 。

警告

注意windows环境动态库只能用于开发联调， 测试， 验证，不能用于正式环境， 禁止 在生产使用。

2.4.3.1. 导入统一SQL脚本到目标库中

由于部分目标方言的特性缺失，统一SQL通过自定义数据库函数的方式来模拟源方言的功能，需要用户将该部分脚本导入到目标库中。SQL脚本包含在官网制品中的 LightDB1.0-unisql-Vxxxxxx-xx-xxx 包下的sql 目录下，包含各个版本的增量脚本和 all 目录下的全量脚本。

2.4.4. 统一SQL脚本升级工具

统一SQL自定义对象脚本可以通过升级工具进行执行，打入目标数据库。建议使用超级用户执行，或者通过具有 CREATE 、EXECUTE、GRANT、SELECT、UPDATE、INSERT权限的用户来执行。 unisql-upgrade-<version>.jar 升级工具jar包位于sql 目录下。执行日志生成在logs 目录下的unisql-upgrade.log文件中。 具体使用方法：

java -jar unisql-upgrade-<version>.jar -S 源端数据库类型 -T 目标端数据库类型 -h 数据库IP -p 数据库端口 -U 数据库用户名 -W 数据库密码 -d 要连接的数据库名称 [-all] [OPTION]...

options:
-S, --source   ,是否必须:是, 源端数据库类型(ORACLE、MYSQL)
-T, --target   ,是否必须:是, 目标端数据库类型(POSTGRESQL、TDSQL_MYSQL、OCEAN_BASE_MYSQL、TDSQL_PG_ORACLE、GAUSSDB_ORACLE、GAUSSDB500_ORACLE)
-h, --host     ,是否必须:是, 数据库IP
-p, --port     ,是否必须:是, 数据库端口
-U, --username ,是否必须:是, 数据库用户名
-W, --password ,是否必须:是, 数据库密码
-d, --dbname   ,是否必须:是, 要连接的数据库名称
-s, --schema   ,是否必须:否, 将sql脚本打入到哪个schema模式下(默认: unisql )
-v, --version  ,是否必须:否, 升级到指定版本(版本号见官网的版本发布历史章节，格式：xx(年份).xx(RP版本).xx(增量版本).xxx(补丁版本)。默认为当前安装包最新版本)
-all, --all    ,是否必须:否, 是否执行全量脚本选项，具有最高优先级(高于-v)，第一次接入时可以选择执行全量脚本，否则进行增量脚本的迭代升级
-help, --help   显示 jar 命令的用法和所有可用的选项

警告

1. 统一sql依赖的自定义对象默认创建在 unisql 的schema下(目标库为TDSQL_MYSQL、OCEAN_BASE_MYSQL则为unisql数据库)。

2. 如果想创建在指定的schema 可以使用脚本升级工具的 --schema 参数指定schema（后续升级时也需要选择同一个schema，同时统一SQL配置文件 unisql.conf 中 unisql.schema 配置项也需要同步变更为指定的schema）。

3. 由于 TDSQL_MYSQL、OCEAN_BASE_MYSQL 无法将某个数据库设置为 共享 状态，当新增了 TDSQL_MYSQL、OCEAN_BASE_MYSQL 用户后，需要为新用户分配统一SQL数据库的函数执行权限。分配方法如下，需要root用户来执行： call unisql.GrantUnisqlPermissions(); 如果初始化时指定了非unisql数据库。则 call 指定的数据库.GrantUnisqlPermissions();

4. 全量脚本可以通过-all选项执行。

5. 增量脚本升级前提，schema已存在且有执行权限

6. 如果是24.2.6版本之前用户，第一次使用升级工具且是增量执行时，需要手动维护统一SQL版本信息表到指定的schema下(默认是unisql)，具体脚本见如下各个源端到目标端的脚本。

7. 输出日志编码格式为UTF-8

8. 用户名、密码、schema不支持中文，如果中间有空格用双引号包裹(内容两边双引号会被识别去除，因此本身内容不支持双引号)

9. 环境必须要有jre（java version>=1.8）

2.4.5. PostgreSQL 目标库脚本

脚本目录为 oracle2postgresql ，建议使用超级用户执行，或者通过具有 CREATE 、EXECUTE、GRANT、SELECT、UPDATE、INSERT权限的用户来执行。 如果是24.2.6版本之前用户，第一次使用升级工具且是增量执行时，需要手动维护统一SQL版本信息表到指定的schema下(默认是unisql),版本号为 xx(年份).xx(RP版本).xx(增量版本).xxx(补丁版本) 见版本发布历史章节。 需要填写升级前使用的实际版本号。

-- unisql_version表用于记录统一SQL版本信息,version为统一SQL版本号，update_time为更新时间。
create table unisql_version (id int primary key,version varchar(20),update_time timestamp(0));
insert into unisql_version values(1,'xx.xx.xx.xxx',now());

2.4.6. TDSQL_MYSQL 目标库脚本

脚本目录为 oracle2tdsql_mysql ，建议使用超级用户执行，或者通过具有 CREATE 、EXECUTE、GRANT、SELECT、UPDATE、INSERT权限的用户来执行。 如果是24.2.6版本之前用户，第一次使用升级工具且是增量执行时，需要手动维护统一SQL版本信息表到指定的database下(默认是unisql),版本号为 xx(年份).xx(RP版本).xx(增量版本).xxx(补丁版本) 见版本发布历史章节。 需要填写升级前使用的实际版本号。

-- unisql_version表用于记录统一SQL版本信息,version为统一SQL版本号，update_time为更新时间。
create table unisql_version (id int primary key,version varchar(20),update_time datetime);
insert into unisql_version values(1,'xx.xx.xx.xxx',now());

2.4.7. OCEAN_BASE_MYSQL 目标库脚本

脚本目录为 oracle2ocean_base_mysql ，建议使用超级用户执行，或者通过具有 CREATE 、EXECUTE、GRANT、SELECT、UPDATE、INSERT权限的用户来执行。 如果是24.2.6版本之前用户，第一次使用升级工具且是增量执行时，需要手动维护统一SQL版本信息表到指定的database下(默认是unisql),版本号为 xx(年份).xx(RP版本).xx(增量版本).xxx(补丁版本) 见版本发布历史章节。 需要填写升级前使用的实际版本号。

-- unisql_version表用于记录统一SQL版本信息,version为统一SQL版本号，update_time为更新时间。
create table unisql_version (id int primary key,version varchar(20),update_time datetime);
insert into unisql_version values(1,'xx.xx.xx.xxx',now());

2.4.8. GAUSSDB_ORACLE 目标库脚本

脚本目录为 oracle2gaussdb_oracle ，建议使用超级用户执行，或者通过具有 CREATE 、EXECUTE、GRANT、SELECT、UPDATE、INSERT权限的用户来执行。 如果是24.2.6版本之前用户，第一次使用升级工具且是增量执行时，需要手动维护统一SQL版本信息表到指定的schema下(默认是unisql),版本号为 xx(年份).xx(RP版本).xx(增量版本).xxx(补丁版本) 见版本发布历史章节。 需要填写升级前使用的实际版本号。

-- unisql_version表用于记录统一SQL版本信息,version为统一SQL版本号，update_time为更新时间。
create table unisql_version (id int primary key,version varchar(20),update_time date);
insert into unisql_version values(1,'xx.xx.xx.xxx',now());

2.4.9. GAUSSDB500_ORACLE 目标库脚本

脚本目录为 mysql2gaussdb500_oracle ，建议使用超级用户执行，或者通过具有 CREATE 、EXECUTE、GRANT、SELECT、UPDATE、INSERT权限的用户来执行。 如果是24.2.6版本之前用户，第一次使用升级工具且是增量执行时，需要手动维护统一SQL版本信息表到指定的schema下(默认是unisql),版本号为 xx(年份).xx(RP版本).xx(增量版本).xxx(补丁版本) 见版本发布历史章节。 需要填写升级前使用的实际版本号。

-- unisql_version表用于记录统一SQL版本信息,version为统一SQL版本号，update_time为更新时间。
create table unisql_version (id int primary key,version varchar(20),update_time date);
insert into unisql_version values(1,'xx.xx.xx.xxx',now());

2.4.10. TDSQL_PG_ORACLE(Oracle模式) 目标库脚本

脚本目录为 oracle2tdsql_pg_oracle ，建议使用超级用户执行，或者通过具有 CREATE 、EXECUTE、GRANT、SELECT、UPDATE、INSERT权限的用户来执行。 如果是24.2.6版本之前用户，第一次使用升级工具且是增量执行时，需要手动维护统一SQL版本信息表到指定的schema下(默认是unisql),版本号为 xx(年份).xx(RP版本).xx(增量版本).xxx(补丁版本) 见版本发布历史章节。 需要填写升级前使用的实际版本号。

-- unisql_version表用于记录统一SQL版本信息,version为统一SQL版本号，update_time为更新时间。
create table unisql_version (id int primary key,version varchar(20),update_time date);
insert into unisql_version values(1,'xx.xx.xx.xxx',now());

2.4.10.1. 在项目中使用统一SQL

2.4.11. 直接调用统一SQL的转换API

统一SQL代理暴露了转换API，用户可以直接调用该API完成统一SQL转换，方法说明如下：

public static String parse(String sql, String sourceDialect, String targetDialect)

注意：

• sql 源方言SQL语句，表示需要转换的SQL语句；

• sourceDialect 源方言，当前支持oracle和mysql；

• targetDialect 目标方言，参见 SQL参考

示例代码

@Test
public void testTransform(){
    // 源SQL语句
    String sql = "select client_id as inner_client_id, client_id, EXTRACT(DAY FROM to_timestamp(to_char(20230823),'yyyymmdd')-to_timestamp(to_char(id_end_date),'yyyymmdd')) as remarks  from hsamlbd.amlbd_ins_client where client_type in ('1','2') and to_date(id_end_date,'yyyymmdd') < to_date(20230823,'yyyymmdd') and id_end_date <> '19000101'";
    // 源方言
    String sourceDialect = DbType.ORACLE.name();
    // 目标方言
    String targetDialect = DbType.POSTGRESQL.name();
    System.out.printf("Before transfer sql is:%s \n",sql);
    String parse  = Transformer.parse(sql, sourceDialect,targetDialect );
    System.out.printf("After transfer sql is:%s \n",parse);
}

// 运行结果
Before transfer sql is:select client_id as inner_client_id, client_id, EXTRACT(DAY FROM to_timestamp(to_char(20230823),'yyyymmdd')-to_timestamp(to_char(id_end_date),'yyyymmdd')) as remarks  from hsamlbd.amlbd_ins_client where client_type in ('1','2') and to_date(id_end_date,'yyyymmdd') < to_date(20230823,'yyyymmdd') and id_end_date <> '19000101'
Aefore transfer sql is:SELECT client_id AS inner_client_id,client_id,EXTRACT(DAY FROM to_timestamp(CAST(20230823 AS text), 'yyyymmdd')-to_timestamp(CAST(id_end_date AS text), 'yyyymmdd')) AS remarks FROM hsamlbd.amlbd_ins_client WHERE client_type IN ('1','2') AND CAST(to_timestamp(id_end_date, 'yyyymmdd') AS timestamp)<CAST(to_timestamp(20230823, 'yyyymmdd') AS timestamp) AND id_end_date<>'19000101'

2.4.12. 通过原生JDBC的方式使用

注意：

• jdbc url 必须以 jdbc:unisql: 开头，表示使用统一SQL代理；

• 连接参数中的 sourceDialect 表示源方言，以下示例是 oracle；

• 连接参数中的 targetDialect 表示目标方言，以下示例是 postgresql；

public static final String URL = "jdbc:unisql:postgresql://10.20.30.40:5432/test?sourceDialect=oracle&targetDialect=postgresql";
public static final String USER = "user";
public static final String PASSWORD = "password";

@Test
void testJdbc() {
    try {
        Class.forName("org.postgresql.Driver");
        Class.forName("com.hundsun.lightdb.unisql.proxy.Driver");
        Connection conn = DriverManager.getConnection(URL, USER, PASSWORD);
        Statement stmt = conn.createStatement();
        // 原生oracle sql语句
        String oracleSQL = "select nation, listagg(city, ',') within GROUP (order by city1, city2 desc) from temp group by nation";
        // 返回postgresql执行结果
        ResultSet rs = stmt.executeQuery(oracleSQL);
        while (rs.next()) {
            System.out.println(rs.getString("nation"));
        }
        conn.close();
    } catch (Exception e) {
        throw new RuntimeException(e);
    }
}

@Test
void testJdbcPrepareStatement() {
    try {
        Class.forName("org.postgresql.Driver");
        Class.forName("com.hundsun.lightdb.unisql.proxy.Driver");
        Connection conn = DriverManager.getConnection(URL, USER, PASSWORD);
        Random random = new Random();
        PreparedStatement pstmt = conn.prepareStatement("insert into t(col) values (?)");
        int i = random.nextInt();
        pstmt.setInt(1, i);
        Statement stmt = conn.createStatement();
        pstmt.executeUpdate();
        log.info("开始随机向t表插入:{}", i);
        conn.close();
    } catch (Exception e) {
        throw new RuntimeException(e);
    }
}

2.4.13. 基于JRESCloud3.X开发框架 + JdbcTemplate使用

1. 如何集成jrescloud微服务可参考 微服务开发手册

2. 配置统一SQL数据源

   spring.datasource.driver-class-name=com.hundsun.lightdb.unisql.proxy.Driver
   spring.datasource.url=jdbc:unisql:postgresql://10.20.30.40:5432/test?sourceDialect=oracle&targetDialect=postgresql
   spring.datasource.username=user
   spring.datasource.password=password
   

3. 通过JdbcTemplate使用统一SQL

   @Autowired
   JdbcTemplate jdbcTemplate;
   
   @Test
   void testSpringboot() {
       // 原生oracle sql语句
       String oracleSQL = "select nation, listagg(city, ',') within GROUP (order by city1, city2 desc) from temp group by nation";
       // 返回postgresql执行结果
       List<Map<String, Object>> list = jdbcTemplate.queryForList(oracleSQL);
   }
   

2.4.14. 基于JRESCloud3.X开发框架 + mybatis + 多数据源使用

1. 如何集成jrescloud微服务可参考 微服务开发手册

2. 根据手册集成多数据源依赖

<dependency>
    <groupId>com.hundsun.jrescloud.middleware</groupId>
    <artifactId>jrescloud-starter-mybatis</artifactId>
</dependency>

3. 使用多数据源注解@EnableCloudDataSource开启多数据源

/**
* 多数据源注解@EnableCloudDataSource，开启多数据源功能
*/
@EnableCloudDataSource
@CloudApplication // 启动类注解
public class UnisqlMultiDataSourceApplication {

    public static void main(String[] args) {
        CloudBootstrap.run(UnisqlMultiDataSourceApplication.class, args);
    }
}

4. 配置多数据源并使用统一SQL格式的jdbcUrl

hs.druid.validationQuery=select 1

hs.datasource.default.driverClassName=org.postgresql.Driver
hs.datasource.default.url=jdbc:postgresql://10.20.30.40:5432/test
hs.datasource.default.username=user
hs.datasource.default.password=password


hs.datasource.mysql.driverClassName=com.mysql.jdbc.Driver
hs.datasource.mysql.url=jdbc:mysql://10.20.30.40:3306/test?useSSL=false&serverTimezone=UTC
hs.datasource.mysql.username=user
hs.datasource.mysql.password=password

hs.datasource.unisql.driverClassName=com.hundsun.lightdb.unisql.proxy.Driver
hs.datasource.unisql.url=jdbc:unisql:postgresql://10.20.30.40:5432/test?sourceDialect=oracle&targetDialect=postgresql
hs.datasource.unisql.username=user
hs.datasource.unisql.password=password

5. 使用数据源指定注解@TargetDataSource指定当前服务类或服务方法所使用的数据源

public interface TestMapper {
    @Select("SELECT nation,STRING_AGG(city, ',' ORDER BY city1,city2 DESC) FROM temp GROUP BY nation")
    List<Map<String, Object>> queryForList();

    @TargetDataSource("unisql") // 指定数据源unisql，该数据源将会使用统一SQL
    @Select("select nation, listagg(city, ',') within GROUP (order by city1, city2 desc) from temp group by nation")
    List<Map> queryForListUsingUnisql();

    @TargetDataSource("unisql")
    List<Map> queryListForUnisql();
}

6. 基于mybatis，指定数据源unisql的mapper接口方法queryListForUnisql对应的SQL映射文件

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">

    <mapper namespace="com.example.unisql.multi.db.mapper.TestMapper">

    <select id="queryListForUnisql" resultType="map">
        select nation, listagg(city, ',') within GROUP (order by city1, city2 desc) from temp group by nation;
    </select>
</mapper>

7. 测试mapper接口方法，确定是否使用了统一SQL

@SpringBootTest
public class UnisqlMybatisTest {
    @Autowired
    private TestMapper testMapper;

    @Test
    void testMybatisUnisql() {
        List<Map> list = testMapper.queryForListUsingUnisql();
        Assert.isTrue(!CollectionUtils.isEmpty(list));
    }

    @Test
    void testMybatisListUnisql() {
        List<Map> list = testMapper.queryListForUnisql();
        Assert.isTrue(!CollectionUtils.isEmpty(list));
    }
}

2.4.15. C技术栈：通过引入统一SQL动态库头文件来使用统一SQL的API

#include <stdio.h>
// 通过引入统一SQL动态库头文件来使用统一SQL的API
#include <unisql.linux.x86_64.h>

int main() {
    // 原始SQL数据库类型
    int sourceDbTypeCode=5;
    // 目标SQL数据库类型
    int targetDbTypeCode=13;
    // 原始SQL
    char* sourceSqlStr="select * from `table` where a=? and b=?";
    // 目标SQL
    char* targetSqlStr=NULL;
    // 动态SQL参数的json字符串:如果用到对比服务时，需要传值。dbName：数据库唯一标识，sqlParameters：SQL预编译后绑定变量的值
    char* jsonParameter = "{\"dbName\":\"usersvr\",\"sqlParameters\":\"[[1$$'2']]\"}";
    // 转换结果 0表示成功，>0表示目标串长度不够，<0表示失败
    int transRet=0;
    // 预设目标SQL的长度为原始SQL的4倍
    int targetSqlStrLen = strlen(sourceSqlStr)*4;
    // 分配内存
    targetSqlStr=(char*)malloc(targetSqlStrLen);

    printf("Before transfer sql is:%s\n",sourceSqlStr);
    // 调用TransferSQL转换函数
    transRet = TransferSQL(sourceDbTypeCode, targetDbTypeCode, sourceSqlStr, targetSqlStr, targetSqlStrLen, jsonParameter);
    if (transRet>0){
        // 预设目标SQL的长度不够，重新分配内存
        targetSqlStr=(char*) realloc (targetSqlStr, transRet) ;
        transRet =TransferSQL (sourceDbTypeCode, targetDbTypeCode, sourceSqlStr, targetSqlStr, transRet, jsonParameter);
    }
    if(transRet == 0)
    {
        printf("After transfer sql is:%s\n",targetSqlStr);
    }else if(transRet < 0)
    {
        printf("SQL Convert Failed:%d\n",transRet);
    }

    // 释放内存
    free(targetSqlStr);
    Sleep(2000);
    return 0;
}

// 运行结果
Before transfer sql is:select * from `table` where a=? and b=?
After transfer sql is:SELECT * FROM `table` WHERE `a`=? AND `b`=?

// 编译加入 -ldl -I -L 动态库完整路径
// gcc -ldl main.c -o main -I./include -L./lib ./lib/unisql.linux.x86_64.so
// export LD_LIBRARY_PATH=动态库路径:$LD_LIBRARY_PATH

2.4.16. C技术栈：在CRES中使用统一SQL

//类的头文件
#ifndef UNISQL_HPP_
#define UNISQL_HPP_

#include <dlfcn.h>
using namespace std;

typedef char* (*Transform_)(char* sourceSQL, char* sourceDialect, char* targetDialect);

class Unisql {

public:
    Unisql()
    {
        libHandle = dlopen("./unisql.linux.x86_64.so", RTLD_LAZY);

        /*根据动态链接库操作句柄与符号，返回符号对应的地址*/
        trsnsform = (Transform_)dlsym(libHandle, "Transform");
    }
    ~Unisql()
    {
        dlclose(libHandle);
    }

private:
    bool  isInit = false;
    void* libHandle;
    Transform_ trsnsform;

public:
    char* Transform(char* sourceSQL, char* sourceDialect, char* targetDialect);
};

#endif /* UNISQL_HPP_ */

//类的实现文件
#include "Unisql.hpp"
#include <iostream>

char* Unisql::Transform(char* sourceSQL, char* sourceDialect, char* targetDialect)
{
    std::cout << "Before transfer sql is:" << sourceSQL << std::endl;

    char* result = (*trsnsform)(sourceSQL, sourceDialect, targetDialect);

    std::cout << "Aefore transfer sql is:" << result << std::endl;
}



//调用示例：
#include <iostream>
#include "Unisql.hpp"

using namespace std;

int main(int argc, char *argv[])
{
    Unisql *uniSql = new Unisql();


    char* csql = "select client_id as inner_client_id, client_id, EXTRACT(DAY FROM to_timestamp(to_char(20230823),'yyyymmdd')-to_timestamp(to_char(id_end_date),'yyyymmdd')) as remarks from hsamlbd.amlbd_ins_client where client_type in ('1','2') and to_date(id_end_date,'yyyymmdd') < to_date(20230823,'yyyymmdd') and id_end_date <> '19000101'";

    char* sourceDialect = "ORACLE";

    char* targetDialect = "POSTGRESQL";

    uniSql->Transform(csql, sourceDialect, targetDialect);

    delete uniSql;


    return 0;
}

//运行结果
Before transfer sql is:select client_id as inner_client_id, client_id, EXTRACT(DAY FROM to_timestamp(to_char(20230823),'yyyymmdd')-to_timestamp(to_char(id_end_date),'yyyymmdd')) as remarks  from hsamlbd.amlbd_ins_client where client_type in ('1','2') and to_date(id_end_date,'yyyymmdd') < to_date(20230823,'yyyymmdd') and id_end_date <> '19000101'
Aefore transfer sql is:SELECT client_id AS inner_client_id,client_id,EXTRACT(DAY FROM to_timestamp(CAST(20230823 AS text), 'yyyymmdd')-to_timestamp(CAST(id_end_date AS text), 'yyyymmdd')) AS remarks FROM hsamlbd.amlbd_ins_client WHERE client_type IN ('1','2') AND CAST(to_timestamp(id_end_date, 'yyyymmdd') AS timestamp)<CAST(to_timestamp(20230823, 'yyyymmdd') AS timestamp) AND id_end_date<>'19000101'