MCPcopy Create free account

hub / github.com/CL-lau/Differ / functions

Functions422 in github.com/CL-lau/Differ

⨍ Functions 422◇ Types & classes 142
↓ 87 callersMethodput
(String url, Map<String, String> headers, String json)
intercept/src/main/java/com/differ/utils/OkHttpClientWrapper.java:170
↓ 65 callersMethodget
@param key redis数据库键 @param clazz 返回对象的具体类型 @return redis中存储的值 @description: 根据redis的key和类型来获取redis中的值
compare/src/main/java/com/differ/compare/cache/ListCacheService.java:22
↓ 44 callersMethodadd
(UserLogin userLogin)
intercept/src/main/java/com/differ/repository/mapper/UserLoginMapper.java:20
↓ 22 callersMethodgetValue
()
intercept/src/main/java/com/differ/entity/enumer/BodyType.java:16
↓ 17 callersMethodexecute
()
compare/src/main/java/com/differ/compare/strategy/Strategy.java:4
↓ 15 callersMethodgetCode
()
intercept/src/main/java/com/differ/entity/enumer/StatusCode.java:12
↓ 12 callersMethodprocessRequest
(Request request, String id)
intercept/src/main/java/com/differ/interfacer/HttpServiceInterface.java:13
↓ 11 callersMethoddelete
@param key redis中的键 @description: 删除redis中的数据
compare/src/main/java/com/differ/compare/cache/ListCacheService.java:28
↓ 10 callersMethodtoJson
(Object object)
compare/src/main/java/com/differ/compare/utils/FastjsonUtils.java:18
↓ 8 callersMethodgetType
()
compare/src/main/java/com/differ/compare/entity/enumer/ServiceType.java:25
↓ 8 callersMethodinsert
(ChangeDto changeDto)
compare/src/main/java/com/differ/compare/repository/db/mapper/ChangeDtoRepository.java:11
↓ 8 callersMethodsave
@param key redis数据库键 @param value redis数据库值 泛型 @description: 把对象存储到redis
compare/src/main/java/com/differ/compare/cache/ListCacheService.java:14
↓ 7 callersMethodinsertHttpResult
(HttpResult httpResult)
intercept/src/main/java/com/differ/repository/mapper/HttpResultMapper.java:10
↓ 6 callersMethodbulidResponse
(int code, String message, String content)
intercept/src/main/java/com/differ/utils/ApiResponseUtil.java:25
↓ 6 callersMethodfromJson
(String json, Class<T> clazz)
compare/src/main/java/com/differ/compare/utils/FastjsonUtils.java:23
↓ 6 callersMethodgetDatabaseName
()
compare/src/main/java/com/differ/compare/config/DatabaseTableConfig.java:14
↓ 6 callersMethodgetKey_DB_Table_Column
(ChangeDto changeDto)
compare/src/main/java/com/differ/compare/service/impl/DBChangeServiceImpl.java:242
↓ 6 callersMethodtransResultMapToJsonV1
(Map<ServiceType, Map<String, List<Object>>> values)
compare/src/main/java/com/differ/compare/service/impl/DBChangeServiceImpl.java:246
↓ 5 callersMethoddispatchRequestWithResponse
(String jsonRequest, String requestPath)
intercept/src/main/java/com/differ/dispatcher/HttpDispatcher.java:203
↓ 5 callersMethodgetCode
()
compare/src/main/java/com/differ/compare/entity/enumer/StatusCode.java:12
↓ 5 callersMethodgetURL
()
intercept/src/main/java/com/differ/entity/request/HttpRequest.java:66
↓ 5 callersMethodrun
(String... args)
DebeziumTest/src/main/java/com/debeziumtest/MyCommandLineRunner.java:13
↓ 4 callersMethodafterPropertiesSet
()
DebeziumTest/src/main/java/com/debeziumtest/entity/DebeziumServerBootstrap.java:35
↓ 4 callersMethoddispatchRequestWithMapResponse
(String jsonRequest, String requestPath)
intercept/src/main/java/com/differ/dispatcher/HttpDispatcher.java:251
↓ 4 callersMethodfindByDatabaseNameAndTableName
(Map<String, String> parameters)
compare/src/main/java/com/differ/compare/repository/db/mapper/ChangeDtoRepository.java:25
↓ 4 callersMethodinsertHttpServiceEntity
(HttpServiceEntity httpServiceEntity)
intercept/src/main/java/com/differ/repository/mapper/HttpServiceEntityMapper.java:14
↓ 4 callersMethodlettuceConnectionFactory
()
compare/src/main/java/com/differ/compare/config/RedisConfig.java:47
↓ 4 callersMethodprocessRequestWithResponse
(String jsonRequest, String id)
intercept/src/main/java/com/differ/interfacer/HttpServiceInterface.java:23
↓ 4 callersMethodprocessResult
(String id, String res)
intercept/src/main/java/com/differ/entity/service/http/HttpServiceEntity.java:77
↓ 4 callersMethodsaveDataWithTTL
(String key, String value, long ttl)
compare/src/main/java/com/differ/compare/utils/RedisDataSyncUtils.java:161
↓ 4 callersMethodsetTables
(List<String> tables)
compare/src/main/java/com/differ/compare/config/DatabaseTableConfig.java:26
↓ 3 callersMethodcreateRequest
(String url, Map<String, String> headers, String json)
intercept/src/main/java/com/differ/utils/OkHttpClientWrapper.java:218
↓ 3 callersMethoddeserialize
(String serialized)
compare/src/main/java/com/differ/compare/entity/handler/ListTypeHandler.java:60
↓ 3 callersMethodfindById
(Long id)
compare/src/main/java/com/differ/compare/repository/db/mapper/ChangeDtoRepository.java:17
↓ 3 callersMethodfromJson
(String json, Class<T> classOfT)
intercept/src/main/java/com/differ/utils/GsonUtils.java:19
↓ 3 callersMethodgetChangeData
(Struct sourceRecordChangeValue, String record)
DebeziumTest/src/main/java/com/debeziumtest/entity/handler/ChangeEventHandler.java:471
↓ 3 callersMethodgetChangeDataMap
(Struct sourceRecordChangeValue, String record)
DebeziumTest/src/main/java/com/debeziumtest/entity/handler/ChangeEventHandler.java:479
↓ 3 callersMethodgetChanges
(String key)
compare/src/main/java/com/differ/compare/cache/ChangeDtoCache.java:18
↓ 3 callersMethodloadTablesFromDatabase
(String url, String username, String password)
compare/src/main/java/com/differ/compare/service/db/DatabaseLoaderService.java:72
↓ 3 callersMethodparseCanalMessage
(CanalMessage canalMessage, ServiceType serviceType)
compare/src/main/java/com/differ/compare/listener/CanalRabbitMQListener.java:91
↓ 3 callersMethodparseDataToMap
(String data)
compare/src/main/java/com/differ/compare/listener/CanalRabbitMQListener.java:178
↓ 3 callersMethodparseJson
(String json)
intercept/src/main/java/com/differ/entity/handler/typehandler/MapTypeHandler.java:49
↓ 3 callersMethodpost
(String url, Map<String, String> headers, RequestBody requestBody)
intercept/src/main/java/com/differ/utils/OkHttpClientWrapper.java:84
↓ 3 callersMethodtimeGen
()
intercept/src/main/java/com/differ/utils/SnowflakeIdUtil.java:50
↓ 3 callersMethodtoJson
(Object obj)
intercept/src/main/java/com/differ/utils/GsonUtils.java:14
↓ 2 callersMethodaddDispatcher
(@Nullable @RequestBody String requestBody, HttpServletRequest request)
intercept/src/main/java/com/differ/controller/HttpController.java:80
↓ 2 callersMethodgetChangesByDB
(DatabaseInfo databaseInfo)
compare/src/main/java/com/differ/compare/service/impl/DBChangeServiceImpl.java:115
↓ 2 callersMethodgetDispatcherCount
()
intercept/src/main/java/com/differ/dispatcher/GlobalDispatcherMap.java:60
↓ 2 callersMethodloadDatabaseInfo
()
compare/src/main/java/com/differ/compare/service/db/DatabaseLoaderService.java:37
↓ 2 callersMethodmapToJson2
(Map<String, String> map)
intercept/src/main/java/com/differ/utils/GsonUtils.java:50
↓ 2 callersMethodnextId
()
intercept/src/main/java/com/differ/utils/SnowflakeIdUtil.java:25
↓ 2 callersMethodqueryAll
()
intercept/src/main/java/com/differ/repository/mapper/UserLoginMapper.java:18
↓ 2 callersMethodqueryByNameAndPwd
(String name, String pwd)
intercept/src/main/java/com/differ/service/impl/UserBiz.java:38
↓ 2 callersMethodselectById
(@Param("id") int id)
intercept/src/main/java/com/differ/repository/mapper/UserMapper.java:21
↓ 2 callersMethodsendMessage
发送消息 @param message
MySQL-Debezium/src/main/java/com/ryan/debezium/service/MessageService.java:12
↓ 2 callersMethodsetDatabaseName
(String databaseName)
compare/src/main/java/com/differ/compare/config/DatabaseTableConfig.java:18
↓ 2 callersMethodshutdown
()
intercept/src/main/java/com/differ/dispatcher/HttpDispatcher.java:448
↓ 2 callersMethodvalidate
(T object)
compare/src/main/java/com/differ/compare/service/ParamValidationService.java:4
↓ 1 callersMethodbulidResponse
(int code, String message, String content)
compare/src/main/java/com/differ/compare/utils/ApiResponseUtil.java:25
↓ 1 callersMethoddeleteById
(int id)
intercept/src/main/java/com/differ/repository/mapper/UserMapper.java:36
↓ 1 callersMethoddeleteChangesFromList
(String key, Integer begin, Integer end)
compare/src/main/java/com/differ/compare/cache/ChangeDtoCache.java:28
↓ 1 callersMethodfilterChangeData
过滤非重要变更数据 @param sourceRecordChangeValue @param currentTableName @return
DebeziumTest/src/main/java/com/debeziumtest/entity/handler/ChangeEventHandler.java:436
↓ 1 callersMethodfilterJsonField
(String fieldName)
DebeziumTest/src/main/java/com/debeziumtest/entity/handler/ChangeEventHandler.java:332
↓ 1 callersMethodfindByDatabaseName
(String databaseName)
compare/src/main/java/com/differ/compare/repository/db/mapper/ChangeDtoRepository.java:23
↓ 1 callersMethodget
(String url, Map<String, String> headers, Map<String, String> params)
intercept/src/main/java/com/differ/utils/OkHttpClientWrapper.java:27
↓ 1 callersMethodgetChange
(String key)
compare/src/main/java/com/differ/compare/cache/ChangeDtoCache.java:12
↓ 1 callersMethodgetChangeData
(Map<String, Object> payload)
compare/src/main/java/com/differ/compare/utils/JSONUtils.java:42
↓ 1 callersMethodgetChangeData
(Map<String, Object> payload)
MySQL-Debezium/src/main/java/com/ryan/debezium/utils/JSONUtils.java:43
↓ 1 callersMethodgetChangeDataInfo
(Struct sourceRecordChangeValue, Map<String, Object> changeMap)
DebeziumTest/src/main/java/com/debeziumtest/entity/handler/ChangeEventHandler.java:391
↓ 1 callersMethodgetChangeTableInfo
(Struct sourceRecordChangeValue)
DebeziumTest/src/main/java/com/debeziumtest/entity/handler/ChangeEventHandler.java:493
↓ 1 callersMethodgetChangesByColumn
(ColumnInfo columnInfo)
compare/src/main/java/com/differ/compare/service/impl/DBChangeServiceImpl.java:215
↓ 1 callersMethodgetChangesByColumns
(List<ColumnInfo> columnInfos)
compare/src/main/java/com/differ/compare/service/impl/DBChangeServiceImpl.java:226
↓ 1 callersMethodgetChangesByDBs
(List<DatabaseInfo> databaseInfos)
compare/src/main/java/com/differ/compare/service/impl/DBChangeServiceImpl.java:120
↓ 1 callersMethodgetChangesByTable
(TableInfo tableInfo)
compare/src/main/java/com/differ/compare/service/impl/DBChangeServiceImpl.java:162
↓ 1 callersMethodgetChangesByTables
(List<TableInfo> tableInfos)
compare/src/main/java/com/differ/compare/service/impl/DBChangeServiceImpl.java:170
↓ 1 callersMethodgetColumnChangesByColumn
(ColumnInfo columnInfo)
compare/src/main/java/com/differ/compare/service/impl/DBChangeServiceImpl.java:183
↓ 1 callersMethodgetColumnChangesByColumns
(List<ColumnInfo> columnInfos)
compare/src/main/java/com/differ/compare/service/impl/DBChangeServiceImpl.java:199
↓ 1 callersMethodgetColumnChangesByDB
(DatabaseInfo databaseInfo)
compare/src/main/java/com/differ/compare/service/impl/DBChangeServiceImpl.java:83
↓ 1 callersMethodgetColumnChangesByDBs
(List<DatabaseInfo> databaseInfos)
compare/src/main/java/com/differ/compare/service/impl/DBChangeServiceImpl.java:99
↓ 1 callersMethodgetColumnChangesByTable
(TableInfo tableInfo)
compare/src/main/java/com/differ/compare/service/impl/DBChangeServiceImpl.java:130
↓ 1 callersMethodgetColumnChangesByTables
(List<TableInfo> tableInfos)
compare/src/main/java/com/differ/compare/service/impl/DBChangeServiceImpl.java:146
↓ 1 callersMethodgetData
(String key)
compare/src/main/java/com/differ/compare/utils/RedisDataSyncUtils.java:167
↓ 1 callersMethodgetErrorCode
()
intercept/src/main/java/com/differ/entity/handler/errorhandler/BusinessException.java:21
↓ 1 callersMethodgetHandleType
(Map<String, Object> payload)
compare/src/main/java/com/differ/compare/utils/JSONUtils.java:21
↓ 1 callersMethodgetHandleType
(Map<String, Object> payload)
MySQL-Debezium/src/main/java/com/ryan/debezium/utils/JSONUtils.java:22
↓ 1 callersMethodgetInstance
公有方法 @return ExecutorService
DebeziumTest/src/main/java/com/debeziumtest/config/DebeziumConfig.java:335
↓ 1 callersMethodgetJsonResultByDB
(DatabaseInfo databaseInfo)
compare/src/main/java/com/differ/compare/service/DBChangeService.java:10
↓ 1 callersMethodgetPayload
(String value)
compare/src/main/java/com/differ/compare/utils/JSONUtils.java:15
↓ 1 callersMethodgetPayload
(String value)
MySQL-Debezium/src/main/java/com/ryan/debezium/utils/JSONUtils.java:16
↓ 1 callersMethodgetTables
()
compare/src/main/java/com/differ/compare/config/DatabaseTableConfig.java:22
↓ 1 callersMethodgetWithResponse
(String url, Map<String, String> headers, Map<String, String> param
intercept/src/main/java/com/differ/utils/OkHttpClientWrapper.java:56
↓ 1 callersMethodinsertUser
(String name, String sex, String pwd, String email)
intercept/src/main/java/com/differ/repository/mapper/UserMapper.java:39
↓ 1 callersMethodloadColumnsForTable
(Connection connection, String tableName)
compare/src/main/java/com/differ/compare/service/db/DatabaseLoaderService.java:106
↓ 1 callersMethodpostJson
(String url, Map<String, String> headers, String json)
intercept/src/main/java/com/differ/utils/OkHttpClientWrapper.java:148
↓ 1 callersMethodpostJsonWithResponse
(String url, Map<String, String> headers, String json)
intercept/src/main/java/com/differ/utils/OkHttpClientWrapper.java:160
↓ 1 callersMethodquery
(String bucketName, String measurementName, long startTime, long endTime)
compare/src/main/java/com/differ/compare/repository/influxdb/InfluxDBRepository.java:71
↓ 1 callersMethodqueryByName1
(String name)
intercept/src/main/java/com/differ/service/impl/UserBiz.java:30
↓ 1 callersMethodqueryByName2
(String name)
intercept/src/main/java/com/differ/service/impl/UserBiz.java:34
↓ 1 callersMethodreceiveChangeEvent
(String value, String name)
compare/src/main/java/com/differ/compare/listener/DebeziumListener.java:43
↓ 1 callersMethodreceiveChangeEvent
(String value, String name)
MySQL-Debezium/src/main/java/com/ryan/debezium/listener/MysqlListener.java:40
next →1–100 of 422, ranked by callers