middleware

ShardingSphereRedisKafkaElastic-Searchdb2es-admin db2es-client

, scfs.xml.datasource.encrypt:

scfs.xml.dimension:

scfs.xml.table:

sharding: enabled: true work-id: 300 show-sql: false acm: datasource: data-id: scfs.xml.datasource.encrypt group: SIJIBAO_ORDER_CENTER_GROUP dimension: data-id: scfs.xml.dimension group: SIJIBAO_ORDER_CENTER_GROUP table: data-id: scfs.xml.table group: SIJIBAO_ORDER_CENTER_GROUP acmConfigPath: acmConfig.properties nacosLocalSnapshotPath: /wyyt/etc/acm/sql_tool nacosLogPath: /wyyt/logs/tomcat/springcloud/sql_tool/ , scfs.tool:

// public void lock() { try (RedisService.Lock lock = this.redisService.getLock(KEY, 10000L, 6000L)) { if ( lock.hasLock()) { System.out.println(": " + lock.lockKey() + " " + lock.requestId()); } else { System.err.println(" "); } } Assert.isNull(this.redisService.get(KEY), "lock"); }

//() @TranKafka public void sendTran() throws Exception { this.kafkaService.send(TOPIC_NAME, "KEY", String.valueOf( System.currentTimeMillis())); }

//() @TranKafka public void sendTranAsync() { this.kafkaService.sendAsync(TOPIC_NAME, "KEY", String.valueOf( System.currentTimeMillis()), (sendResult, throwable) -> { log.info(sendResult.toString()); Assert.isTrue(false, " "); }); Assert.isTrue(false, ""); }

// public void getById() throws Exception { String response = this.elasticSearchService.getById(INDEX_NAME, PRIMARY_KEY_VALUE, String.class); System.out.println(response); }

// public void test06_search() throws Exception { SearchRequest searchRequest = new SearchRequest(INDEX_NAME); BoolQueryBuilder boolQueryBuilder = new BoolQueryBuilder(); boolQueryBuilder.must(QueryBuilders.rangeQuery("id").gte(1) .lte(20)); //mustSQL whereAND; shouldOR boolQueryBuilder.must(QueryBuilders.matchQuery("remark", " ABCDEFGHIJKLMNOPQRSTUVWXYZ_1234567890987654321")); //match SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); searchSourceBuilder.query(boolQueryBuilder); searchSourceBuilder.from(0); //, searchSourceBuilder.size(10);//document, searchSourceBuilder.sort("row_create_time", SortOrder.ASC); // searchSourceBuilder.fetchSource(new String[]{"id", "name", "remark"}, new String[]{}); searchRequest.source( searchSourceBuilder); List response = this.elasticSearchService.select(searchRequest, String.class); for (String s : response) { System.out.println(s); } }

// public void page() throws IOException { SearchRequest searchRequest = new SearchRequest(INDEX_NAME); BoolQueryBuilder boolQueryBuilder = new BoolQueryBuilder(); boolQueryBuilder.must(QueryBuilders.matchPhraseQuery("id", " 1")); //match SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); searchSourceBuilder.query( boolQueryBuilder); searchRequest.source(searchSourceBuilder); IPage page = this.elasticSearchService.page( searchRequest, TestEntity.class, new Page<>(1, 10)); System.out.println(page.getRecords()); }