提交 de4d802a 作者: guofeng

1

上级 bbbb0a87
...@@ -487,12 +487,12 @@ public interface GPMapper { ...@@ -487,12 +487,12 @@ public interface GPMapper {
public void updateTransformNewNode(TransformNewNode item); public void updateTransformNewNode(TransformNewNode item);
public List<TransformNewNode> selectTransformNewNodeCheck(TransformNewNode build); public List<TransformNewNode> selectTransformNewNodeCheck(TransformNewNode build);
@Cacheable(key = "#root.method.name+':'+#p0.id", unless="#result == null") // @Cacheable(key = "#root.method.name+':'+#p0.id", unless="#result == null")
public TransformHistoryNode selectTransformHistoryNode(TransformHistoryNode data); public TransformHistoryNode selectTransformHistoryNode(TransformHistoryNode data);
public void insertTransformHistoryNode(TransformHistoryNode element); public void insertTransformHistoryNode(TransformHistoryNode element);
@CacheEvict(key = "'selectTransformHistoryNode'+':'+#p0.id") // @CacheEvict(key = "'selectTransformHistoryNode'+':'+#p0.id")
public void deleteTransformHistoryNode(TransformHistoryNode item); public void deleteTransformHistoryNode(TransformHistoryNode item);
@CacheEvict(key = "'selectTransformHistoryNode'+':'+#p0.id") // @CacheEvict(key = "'selectTransformHistoryNode'+':'+#p0.id")
public void updateTransformHistoryNode(TransformHistoryNode item); public void updateTransformHistoryNode(TransformHistoryNode item);
public List<TransformHistoryNode> selectTransformHistoryNodeCheck(TransformHistoryNode build); public List<TransformHistoryNode> selectTransformHistoryNodeCheck(TransformHistoryNode build);
......
...@@ -30,7 +30,7 @@ druid.hana.maxPoolPreparedStatementPerConnectionSize: 5 ...@@ -30,7 +30,7 @@ druid.hana.maxPoolPreparedStatementPerConnectionSize: 5
druid.hana.mapper: classpath:/mapper/hana/*Mapper_hana.xml druid.hana.mapper: classpath:/mapper/hana/*Mapper_hana.xml
druid.mysql.driverClassName: com.mysql.cj.jdbc.Driver druid.mysql.driverClassName: com.mysql.cj.jdbc.Driver
druid.mysql.url: jdbc:mysql://192.168.80.31:3306/huazhengxincai_main?zeroDateTimeBehavior=convertToNull&autoReconnect=true&useSSL=false druid.mysql.url: jdbc:mysql://192.168.80.31:3306/huazhengxincai_main?zeroDateTimeBehavior=convertToNull&autoReconnect=true&useSSL=false&serverTimezone=Asia/Shanghai
druid.mysql.username: hzxc_reader druid.mysql.username: hzxc_reader
druid.mysql.password: uXu9hRwJFhA6FyNXl_m druid.mysql.password: uXu9hRwJFhA6FyNXl_m
druid.mysql.validationQuery: SELECT '1' druid.mysql.validationQuery: SELECT '1'
......
...@@ -30,7 +30,7 @@ druid.hana.maxPoolPreparedStatementPerConnectionSize: 5 ...@@ -30,7 +30,7 @@ druid.hana.maxPoolPreparedStatementPerConnectionSize: 5
druid.hana.mapper: classpath:/mapper/hana/*Mapper_hana.xml druid.hana.mapper: classpath:/mapper/hana/*Mapper_hana.xml
druid.mysql.driverClassName: com.mysql.cj.jdbc.Driver druid.mysql.driverClassName: com.mysql.cj.jdbc.Driver
druid.mysql.url: jdbc:mysql://192.168.80.33:3306/huazhengxincai_main?zeroDateTimeBehavior=convertToNull&autoReconnect=true&useSSL=false druid.mysql.url: jdbc:mysql://192.168.80.33:3306/huazhengxincai_main?zeroDateTimeBehavior=convertToNull&autoReconnect=true&useSSL=false&serverTimezone=Asia/Shanghai
druid.mysql.username: hzxc_reader druid.mysql.username: hzxc_reader
druid.mysql.password: LCik4PEul2X-ZPujgG7ap druid.mysql.password: LCik4PEul2X-ZPujgG7ap
druid.mysql.validationQuery: SELECT '1' druid.mysql.validationQuery: SELECT '1'
......
...@@ -30,7 +30,7 @@ druid.hana.maxPoolPreparedStatementPerConnectionSize: 5 ...@@ -30,7 +30,7 @@ druid.hana.maxPoolPreparedStatementPerConnectionSize: 5
druid.hana.mapper: classpath:/mapper/hana/*Mapper_hana.xml druid.hana.mapper: classpath:/mapper/hana/*Mapper_hana.xml
druid.mysql.driverClassName: com.mysql.cj.jdbc.Driver druid.mysql.driverClassName: com.mysql.cj.jdbc.Driver
druid.mysql.url: jdbc:mysql://192.168.80.33:3306/huazhengxincai_main?zeroDateTimeBehavior=convertToNull&autoReconnect=true&useSSL=false druid.mysql.url: jdbc:mysql://192.168.80.33:3306/huazhengxincai_main?zeroDateTimeBehavior=convertToNull&autoReconnect=true&useSSL=false&serverTimezone=Asia/Shanghai
druid.mysql.username: hzxc_reader druid.mysql.username: hzxc_reader
druid.mysql.password: LCik4PEul2X-ZPujgG7ap druid.mysql.password: LCik4PEul2X-ZPujgG7ap
druid.mysql.validationQuery: SELECT '1' druid.mysql.validationQuery: SELECT '1'
......
...@@ -27,4 +27,6 @@ select q.vbeln,r.pernr from ${hana_user}.vbap q ...@@ -27,4 +27,6 @@ select q.vbeln,r.pernr from ${hana_user}.vbap q
where q.mandt = '800' and r.pernr is not null and a.vbeln = '111' where q.mandt = '800' and r.pernr is not null and a.vbeln = '111'
group by q.vbeln,r.pernr group by q.vbeln,r.pernr
CALL IDENTITY();
\ No newline at end of file SELECT IDENTITY_VAL_LOCAL() FROM SYSIBM.SYSDUMMY1;
select dbinfo('sqlca.sqlerrd1') from sapabap1.systables where tabid=1;
update vbap set hashresult = null; update vbap set hashresult = null;
...@@ -13,7 +13,6 @@ com.huazheng.project.greenplum.source.mssql2.SysSAPreturnNoSource.run(SourceCont ...@@ -13,7 +13,6 @@ com.huazheng.project.greenplum.source.mssql2.SysSAPreturnNoSource.run(SourceCont
com.huazheng.project.greenplum.service.impl.GPServiceImpl.processSysSAPreturnNo(String, Collector<SysSAPreturnNo>) com.huazheng.project.greenplum.service.impl.GPServiceImpl.processSysSAPreturnNo(String, Collector<SysSAPreturnNo>)
com.huazheng.project.greenplum.service.impl.GPServiceImpl.sinkSysSAPreturnNo(SysSAPreturnNo) com.huazheng.project.greenplum.service.impl.GPServiceImpl.sinkSysSAPreturnNo(SysSAPreturnNo)
发送端 发送端
watch -n 1 redis-cli -n 1 --raw mget "huazheng:SysSAPreturnNo:sendcount", "huazheng:SysSAPreturnNo:rowids", "huazheng:list:SysSAPreturnNo" watch -n 1 redis-cli -n 1 --raw mget "huazheng:SysSAPreturnNo:sendcount", "huazheng:SysSAPreturnNo:rowids", "huazheng:list:SysSAPreturnNo"
...@@ -26,3 +25,16 @@ redis-cli -n 1 --raw set "huazheng:Vbak:rowids" 107902 ...@@ -26,3 +25,16 @@ redis-cli -n 1 --raw set "huazheng:Vbak:rowids" 107902
redis-cli -n 0 --raw keys "huazheng::selectTransformHistoryNode:*" | xargs redis-cli -n 0 del
watch -n 1 redis-cli -n 1 --raw get "huazheng:checkUpdate:TransformHistoryNode:rowids"
watch -n 1 redis-cli -n 1 --raw get "huazheng:TransformHistoryNode:sendcount"
watch -n 1 redis-cli -n 1 --raw get "huazheng:TransformHistoryNode:receivecount"
watch -n 1 redis-cli -n 1 --raw get "huazheng:TransformHistoryNode:id"
redis-cli -n 1 --raw set "huazheng:TransformHistoryNode:id" 0
redis-cli -n 1 --raw set "huazheng:checkUpdate:TransformHistoryNode:rowids" 0
watch -n 1 redis-cli -n 1 --raw mget "huazheng:TransformHistoryNode:sendcount" \
"huazheng:TransformHistoryNode:receivecount" \
"huazheng:TransformHistoryNode:id" \
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论