Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/CL-lau/Differ
/ functions
Functions
422 in github.com/CL-lau/Differ
⨍
Functions
422
◇
Types & classes
142
Method
main
(String[] args)
log/src/main/java/com/differ/Main.java:4
Method
main
(String[] args)
view/src/main/java/com/differ/Main.java:4
Method
main
(String[] args)
MySQL-Debezium/src/main/java/com/ryan/debezium/Application.java:13
Method
main
(String[] args)
flowController/src/main/java/com/differ/Main.java:4
Method
main
(String[] args)
publish/src/main/java/com/differ/Main.java:4
Method
mapToJson
(Map<String, Object> map)
intercept/src/main/java/com/differ/utils/GsonUtils.java:45
Method
moveFile
(String sourcePath, String destinationPath)
compare/src/main/java/com/differ/compare/utils/FileUtil.java:37
Method
mysqlProperties
()
compare/src/main/java/com/differ/compare/config/MysqlConfig.java:37
Method
mysqlProperties
()
MySQL-Debezium/src/main/java/com/ryan/debezium/config/MysqlConfig.java:37
Method
onFailure
(@NotNull Call call, @NotNull IOException e)
intercept/src/main/java/com/differ/callback/httpCallback.java:12
Method
parseDataInListToMap
(String data)
compare/src/main/java/com/differ/compare/listener/CanalRabbitMQListener.java:163
Method
parseDateTime
(String dateTime, String format)
compare/src/main/java/com/differ/compare/utils/DateTimeUtil.java:20
Method
postJsonAsync
(String url, Map<String, String> headers, String json, final Callback callback)
intercept/src/main/java/com/differ/utils/OkHttpClientWrapper.java:213
Method
postWithResponse
(String url, Map<String, String> headers, RequestBody requestBody)
intercept/src/main/java/com/differ/utils/OkHttpClientWrapper.java:106
Method
processRequest
(Request request, String id)
intercept/src/main/java/com/differ/entity/service/http/HttpServiceEntity.java:33
Method
processRequestWithResponse
(String jsonRequest, String id)
intercept/src/main/java/com/differ/entity/service/http/HttpServiceEntity.java:65
Method
publishMessage
(String channel, String message)
compare/src/main/java/com/differ/compare/utils/RedisDataSyncUtils.java:211
Method
queryAll
()
intercept/src/test/java/com/differ/UserBizTest.java:45
Method
queryAll
()
intercept/src/main/java/com/differ/service/impl/UserBiz.java:26
Method
queryByName
()
intercept/src/test/java/com/differ/UserBizTest.java:50
Method
queryByName
(String username)
intercept/src/main/java/com/differ/repository/mapper/UserLoginMapper.java:22
Method
readFileBytes
(String filePath)
compare/src/main/java/com/differ/compare/utils/FileUtil.java:29
Method
redisTemplateChangeDto
()
compare/src/main/java/com/differ/compare/config/RedisConfig.java:94
Method
redisTemplateObject
()
compare/src/main/java/com/differ/compare/config/RedisConfig.java:56
Method
redisTemplateStringSelf
()
compare/src/main/java/com/differ/compare/config/RedisConfig.java:75
Method
redisTemplateT
()
compare/src/main/java/com/differ/compare/config/RedisConfig.java:113
Method
removeDispatcher
(String key, Dispatcher dispatcher)
intercept/src/main/java/com/differ/dispatcher/GlobalDispatcherMap.java:36
Method
removeDispatcherWithReturn
(String key)
intercept/src/main/java/com/differ/dispatcher/GlobalDispatcherMap.java:52
Method
replaceString
(String source, String target, String replacement)
compare/src/main/java/com/differ/compare/utils/StringUtil.java:20
Method
save
(String key, T value)
compare/src/main/java/com/differ/compare/cache/impl/ListCacheServiceImpl.java:36
Method
save
(ColumnInfo columnInfo)
compare/src/main/java/com/differ/compare/repository/db/mapper/ColumnInfoRepository.java:20
Method
save
(TableInfo tableInfo)
compare/src/main/java/com/differ/compare/repository/db/mapper/TableInfoRepository.java:19
Method
save
(DatabaseInfo databaseInfo)
compare/src/main/java/com/differ/compare/repository/db/mapper/DatabaseInfoRepository.java:20
Method
saveAll
@param key redis中的键 @param values 存储对象列表 @description: 存储Java对象list到redis的list中
compare/src/main/java/com/differ/compare/cache/ListCacheService.java:35
Method
saveAll
(String key, List<T> values)
compare/src/main/java/com/differ/compare/cache/impl/ListCacheServiceImpl.java:53
Method
saveChange
(String key, ChangeDto changeDto)
compare/src/main/java/com/differ/compare/cache/impl/ChangeDtoCacheImpl.java:39
Method
saveChangeDto
@param key redis 键 @param changeDto redis 值 @description: 存储ChangeDto到redis以及数据库 并且根据yml中的时间设置来完成失效时间设置
compare/src/main/java/com/differ/compare/utils/RedisDataSyncUtils.java:83
Method
saveChangeToList
(String key, ChangeDto changeDto)
compare/src/main/java/com/differ/compare/cache/impl/ChangeDtoCacheImpl.java:77
Method
saveChanges
(String key, List<ChangeDto> changeDtoList)
compare/src/main/java/com/differ/compare/cache/impl/ChangeDtoCacheImpl.java:56
Method
saveChangesToList
(String key, List<ChangeDto> changeDtoList)
compare/src/main/java/com/differ/compare/cache/ChangeDtoCache.java:22
Method
saveChangesToList
(String key, List<ChangeDto> changeDtoList)
compare/src/main/java/com/differ/compare/cache/impl/ChangeDtoCacheImpl.java:84
Method
saveColumnInfo
(String key, ColumnInfo columnInfo)
compare/src/main/java/com/differ/compare/utils/RedisDataSyncUtils.java:141
Method
saveData
@param key: redis 数据库的键 @param value: redis 数据库存储的值 @description: 永久存储键值到数据库
compare/src/main/java/com/differ/compare/utils/RedisDataSyncUtils.java:74
Method
saveTableInfo
(String key, TableInfo tableInfo)
compare/src/main/java/com/differ/compare/utils/RedisDataSyncUtils.java:146
Method
selectAllHttpServiceEntities
()
intercept/src/main/java/com/differ/repository/mapper/HttpServiceEntityMapper.java:13
Method
selectByAccountAndPwd
()
intercept/src/test/java/com/differ/UserBizTest.java:40
Method
selectById
(int id)
intercept/src/main/java/com/differ/service/impl/UserBiz.java:22
Method
selectHttpResultById
(int id)
intercept/src/main/java/com/differ/repository/mapper/HttpResultMapper.java:9
Method
selectHttpServiceEntityById
(long id)
intercept/src/main/java/com/differ/repository/mapper/HttpServiceEntityMapper.java:12
Method
selectTableRelationById
(int id)
intercept/src/main/java/com/differ/repository/mapper/TableRelationMapper.java:10
Method
sendMessage
(Message message)
compare/src/main/java/com/differ/compare/service/debezium/MessageService.java:6
Method
sendMessage
(Message message)
compare/src/main/java/com/differ/compare/service/debezium/impl/MessageServiceImpl.java:17
Method
sendMessage
(Message message)
MySQL-Debezium/src/main/java/com/ryan/debezium/service/impl/MessageServiceImpl.java:13
Method
sendRequestWithResponse
(Request request)
intercept/src/main/java/com/differ/utils/OkHttpClientWrapper.java:138
Method
sendWebSocketMessage
(WebSocket webSocket, String message, Runnable onMessageReceived)
intercept/src/main/java/com/differ/utils/OkHttpClientWrapper.java:240
Method
setChangeEventConfig
(ChangeEventHandler changeEventHandler)
DebeziumTest/src/main/java/com/debeziumtest/config/DebeziumConfig.java:70
Method
setDatabase
(List<DatabaseData> database)
compare/src/main/java/com/differ/compare/config/MysqlConfig.java:21
Method
setDatabase
(List<DatabaseData> database)
MySQL-Debezium/src/main/java/com/ryan/debezium/config/MysqlConfig.java:22
Method
setDatabases
(List<DatabaseTableConfig> databases)
compare/src/main/java/com/differ/compare/config/BinlogConfig.java:17
Method
setDatacenterId
(long id)
intercept/src/main/java/com/differ/utils/SnowflakeIdUtil.java:61
Method
setHttpService
(@Nullable @RequestBody(required = false) String requestBody, HttpServletRequest request)
intercept/src/main/java/com/differ/controller/HttpController.java:27
Method
setHttpService
(String serviceString)
intercept/src/main/java/com/differ/service/impl/HttpServiceImpl.java:55
Method
setHttpService
()
DebeziumTest/src/main/java/com/debeziumtest/controller/HttpResultController.java:16
Method
setInject
(ChangeDtoRepository changeDtoMapper, ColumnInfoRepository columnInfoRepository,
compare/src/main/java/com/differ/compare/utils/RedisDataSyncUtils.java:58
Method
setInject
(DBChangeServiceImpl dbChangeService, ParamValidationServiceImpl paramValidationService)
compare/src/main/java/com/differ/compare/controller/result/ChangeController.java:27
Method
setInject
(ChangeDtoRepository changeDtoMapper)
compare/src/main/java/com/differ/compare/service/impl/DBChangeServiceImpl.java:48
Method
setInject
(DatabaseInfoRepository databaseInfoRepository, TableInfoRepository tableInfoRepository, ColumnInfoRepository
compare/src/main/java/com/differ/compare/service/db/DatabaseLoaderService.java:30
Method
setInject
(@Qualifier("writeApi") WriteApiBlocking writeApiBlocking, @Qualifier("influxDBClient") InfluxDBClient influxD
compare/src/main/java/com/differ/compare/repository/influxdb/InfluxDBRepository.java:31
Method
setInject
(ChangeDtoRepository changeDtoMapper, InfluxDBRepository influxDBRepository)
compare/src/main/java/com/differ/compare/listener/CanalRabbitMQListener.java:43
Method
setInjections
(InfluxDBClient influxDBClient)
compare/src/main/java/com/differ/compare/service/influxdb/InfluxDbInitializer.java:26
Method
setMyDependency
(GlobalDispatcherMap globalDispatcherMap, HttpResultMapper httpResultMapper, HttpServiceEntityMapper httpServi
intercept/src/main/java/com/differ/service/impl/HttpServiceImpl.java:48
Method
setNonNullParameter
(PreparedStatement ps, int i, RequestType parameter, JdbcType jdbcType)
intercept/src/main/java/com/differ/entity/handler/typehandler/RequestTypeHandler.java:20
Method
setNonNullParameter
(PreparedStatement ps, int i, Map<String, String> parameter, JdbcType jdbcType)
intercept/src/main/java/com/differ/entity/handler/typehandler/MapTypeHandler.java:20
Method
setNonNullParameter
(PreparedStatement ps, int i, BodyType parameter, JdbcType jdbcType)
intercept/src/main/java/com/differ/entity/handler/typehandler/BodyTypeHandler.java:20
Method
setNonNullParameter
(PreparedStatement ps, int i, ServiceType parameter, JdbcType jdbcType)
intercept/src/main/java/com/differ/entity/handler/typehandler/ServiceTypeHandler.java:20
Method
setNonNullParameter
(PreparedStatement ps, int i, List parameter, JdbcType jdbcType)
compare/src/main/java/com/differ/compare/entity/handler/ListTypeHandler.java:24
Method
setNonNullParameter
(PreparedStatement ps, int i, ServiceType parameter, JdbcType jdbcType)
compare/src/main/java/com/differ/compare/entity/handler/typehandler/ServiceTypeHandler.java:20
Method
setService
(@RequestBody(required = false) String requestBody, HttpServletRequest request)
intercept/src/main/java/com/differ/controller/HttpReciveController.java:24
Method
setService
(@RequestBody(required = false) String requestBody, HttpServletRequest request)
intercept/src/main/java/com/differ/controller/HttpController.java:38
Method
setStrategy
(DebeziumStrategy debeziumStrategy, CanalStrategy canalStrategy, DirectStrategy directStrategy)
compare/src/main/java/com/differ/compare/config/StrategyConfig.java:25
Method
setWorkerId
(long id)
intercept/src/main/java/com/differ/utils/SnowflakeIdUtil.java:54
Method
sqlServerTimelyExecutor
实例化sql server 实时同步服务类,执行任务 @param configuration @return
DebeziumTest/src/main/java/com/debeziumtest/config/DebeziumConfig.java:261
Method
sqlSessionFactory
()
compare/src/main/java/com/differ/compare/config/MyBatisConfig.java:24
Method
start
()
DebeziumTest/src/main/java/com/debeziumtest/config/DebeziumConfig.java:282
Method
start
()
DebeziumTest/src/main/java/com/debeziumtest/entity/DebeziumServerBootstrap.java:22
Method
start
()
compare/src/main/java/com/differ/compare/listener/DebeziumListener.java:68
Method
start
()
MySQL-Debezium/src/main/java/com/ryan/debezium/listener/MysqlListener.java:65
Method
stop
()
DebeziumTest/src/main/java/com/debeziumtest/config/DebeziumConfig.java:288
Method
stop
()
DebeziumTest/src/main/java/com/debeziumtest/entity/DebeziumServerBootstrap.java:26
Method
stop
()
compare/src/main/java/com/differ/compare/listener/DebeziumListener.java:75
Method
stop
()
MySQL-Debezium/src/main/java/com/ryan/debezium/listener/MysqlListener.java:72
Method
strategyContext
()
compare/src/main/java/com/differ/compare/config/StrategyConfig.java:31
Method
tableList
()
compare/src/main/java/com/differ/compare/config/MysqlConfig.java:26
Method
tableList
()
MySQL-Debezium/src/main/java/com/ryan/debezium/config/MysqlConfig.java:26
Method
testChangeDtoCacheService
()
compare/src/test/java/com/differ/compare/ListCacheServiceTest.java:25
Method
testColumnInfoOperations
()
compare/src/test/java/com/differ/compare/DatabaseInfoRepositoryTest.java:128
Method
testDatabaseInfoOperations
()
compare/src/test/java/com/differ/compare/DatabaseInfoRepositoryTest.java:34
Method
testGetUser
()
intercept/src/test/java/com/differ/MybatisTest.java:28
Method
testInfluxDB
()
compare/src/test/java/com/differ/compare/InfluxDBTest.java:23
Method
testLoadDatabaseInfo
()
intercept/src/test/java/com/differ/DatabaseLoaderServiceTest.java:20
← previous
next →
301–400 of 422, ranked by callers