重庆分公司,新征程启航
为企业提供网站建设、域名注册、服务器等服务
安华金和的数据库加密产品目前在TDE技术路线 上我了解到的支持Oracle、MySQL、SQL Server,达梦、金仓。至于支持的版本你可以直接咨询厂家,我觉得人家做产品肯定是为了更好的售卖,所以主流的与国产主流的产品的不同版本都差不多支持。仅个人观点,喜欢的话就采纳~
让客户满意是我们工作的目标,不断超越客户的期望值来自于我们对这个行业的热爱。我们立志把好的技术通过有效、简单的方式提供给客户,将通过不懈努力成为客户在信息化领域值得信任、有价值的长期合作伙伴,公司提供的服务项目有:申请域名、网络空间、营销软件、网站建设、徐州网站维护、网站推广。
pagehelper是mybatis封装的一个分页查询接口,支持oracle的。
此外还支持mysqlsqlserver和db2等主流数据库。
目前业务上有同步数据到sqlServer的需求,但是flink1.12.1版本的JdbcDialects不支持SqlServerDialect,
科学上网后发现袋鼠云的flinkStreamSql已经有支持sqlserver,那就开始动手,参考实现一波
主要实现getUpsertStatement的方法,本来以为能直接copy一波flinkStreamSql 的实现,结果发现
报错 SQL statement must not contain ? character.
查看源码发现, flink在构建mysql的Statement,是先把需要替换的字段前面拼接了 : fieldNames,然后在org.apache.flink.connector.jdbc.statement.FieldNamedPreparedStatementImpl类的parseNamedStatement 替换成 ?号, 既然如此,就针对了buildDualQueryStatement进行修改
完整的SqlServerDialect文件
最后替换原有的flink-jar包后,就可以用类似flink定义mysql的ddl进行定义表了
注意url写法为:jdbc:jtds:sqlserver://xxx:1433;databaseName=master;
[flinkStreamSQL链接]