MCPcopy Create free account

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

Functions422 in github.com/CL-lau/Differ

Methodmain
(String[] args)
log/src/main/java/com/differ/Main.java:4
Methodmain
(String[] args)
view/src/main/java/com/differ/Main.java:4
Methodmain
(String[] args)
MySQL-Debezium/src/main/java/com/ryan/debezium/Application.java:13
Methodmain
(String[] args)
flowController/src/main/java/com/differ/Main.java:4
Methodmain
(String[] args)
publish/src/main/java/com/differ/Main.java:4
MethodmapToJson
(Map<String, Object> map)
intercept/src/main/java/com/differ/utils/GsonUtils.java:45
MethodmoveFile
(String sourcePath, String destinationPath)
compare/src/main/java/com/differ/compare/utils/FileUtil.java:37
MethodmysqlProperties
()
compare/src/main/java/com/differ/compare/config/MysqlConfig.java:37
MethodmysqlProperties
()
MySQL-Debezium/src/main/java/com/ryan/debezium/config/MysqlConfig.java:37
MethodonFailure
(@NotNull Call call, @NotNull IOException e)
intercept/src/main/java/com/differ/callback/httpCallback.java:12
MethodparseDataInListToMap
(String data)
compare/src/main/java/com/differ/compare/listener/CanalRabbitMQListener.java:163
MethodparseDateTime
(String dateTime, String format)
compare/src/main/java/com/differ/compare/utils/DateTimeUtil.java:20
MethodpostJsonAsync
(String url, Map<String, String> headers, String json, final Callback callback)
intercept/src/main/java/com/differ/utils/OkHttpClientWrapper.java:213
MethodpostWithResponse
(String url, Map<String, String> headers, RequestBody requestBody)
intercept/src/main/java/com/differ/utils/OkHttpClientWrapper.java:106
MethodprocessRequest
(Request request, String id)
intercept/src/main/java/com/differ/entity/service/http/HttpServiceEntity.java:33
MethodprocessRequestWithResponse
(String jsonRequest, String id)
intercept/src/main/java/com/differ/entity/service/http/HttpServiceEntity.java:65
MethodpublishMessage
(String channel, String message)
compare/src/main/java/com/differ/compare/utils/RedisDataSyncUtils.java:211
MethodqueryAll
()
intercept/src/test/java/com/differ/UserBizTest.java:45
MethodqueryAll
()
intercept/src/main/java/com/differ/service/impl/UserBiz.java:26
MethodqueryByName
()
intercept/src/test/java/com/differ/UserBizTest.java:50
MethodqueryByName
(String username)
intercept/src/main/java/com/differ/repository/mapper/UserLoginMapper.java:22
MethodreadFileBytes
(String filePath)
compare/src/main/java/com/differ/compare/utils/FileUtil.java:29
MethodredisTemplateChangeDto
()
compare/src/main/java/com/differ/compare/config/RedisConfig.java:94
MethodredisTemplateObject
()
compare/src/main/java/com/differ/compare/config/RedisConfig.java:56
MethodredisTemplateStringSelf
()
compare/src/main/java/com/differ/compare/config/RedisConfig.java:75
MethodredisTemplateT
()
compare/src/main/java/com/differ/compare/config/RedisConfig.java:113
MethodremoveDispatcher
(String key, Dispatcher dispatcher)
intercept/src/main/java/com/differ/dispatcher/GlobalDispatcherMap.java:36
MethodremoveDispatcherWithReturn
(String key)
intercept/src/main/java/com/differ/dispatcher/GlobalDispatcherMap.java:52
MethodreplaceString
(String source, String target, String replacement)
compare/src/main/java/com/differ/compare/utils/StringUtil.java:20
Methodsave
(String key, T value)
compare/src/main/java/com/differ/compare/cache/impl/ListCacheServiceImpl.java:36
Methodsave
(ColumnInfo columnInfo)
compare/src/main/java/com/differ/compare/repository/db/mapper/ColumnInfoRepository.java:20
Methodsave
(TableInfo tableInfo)
compare/src/main/java/com/differ/compare/repository/db/mapper/TableInfoRepository.java:19
Methodsave
(DatabaseInfo databaseInfo)
compare/src/main/java/com/differ/compare/repository/db/mapper/DatabaseInfoRepository.java:20
MethodsaveAll
@param key redis中的键 @param values 存储对象列表 @description: 存储Java对象list到redis的list中
compare/src/main/java/com/differ/compare/cache/ListCacheService.java:35
MethodsaveAll
(String key, List<T> values)
compare/src/main/java/com/differ/compare/cache/impl/ListCacheServiceImpl.java:53
MethodsaveChange
(String key, ChangeDto changeDto)
compare/src/main/java/com/differ/compare/cache/impl/ChangeDtoCacheImpl.java:39
MethodsaveChangeDto
@param key redis 键 @param changeDto redis 值 @description: 存储ChangeDto到redis以及数据库 并且根据yml中的时间设置来完成失效时间设置
compare/src/main/java/com/differ/compare/utils/RedisDataSyncUtils.java:83
MethodsaveChangeToList
(String key, ChangeDto changeDto)
compare/src/main/java/com/differ/compare/cache/impl/ChangeDtoCacheImpl.java:77
MethodsaveChanges
(String key, List<ChangeDto> changeDtoList)
compare/src/main/java/com/differ/compare/cache/impl/ChangeDtoCacheImpl.java:56
MethodsaveChangesToList
(String key, List<ChangeDto> changeDtoList)
compare/src/main/java/com/differ/compare/cache/ChangeDtoCache.java:22
MethodsaveChangesToList
(String key, List<ChangeDto> changeDtoList)
compare/src/main/java/com/differ/compare/cache/impl/ChangeDtoCacheImpl.java:84
MethodsaveColumnInfo
(String key, ColumnInfo columnInfo)
compare/src/main/java/com/differ/compare/utils/RedisDataSyncUtils.java:141
MethodsaveData
@param key: redis 数据库的键 @param value: redis 数据库存储的值 @description: 永久存储键值到数据库
compare/src/main/java/com/differ/compare/utils/RedisDataSyncUtils.java:74
MethodsaveTableInfo
(String key, TableInfo tableInfo)
compare/src/main/java/com/differ/compare/utils/RedisDataSyncUtils.java:146
MethodselectAllHttpServiceEntities
()
intercept/src/main/java/com/differ/repository/mapper/HttpServiceEntityMapper.java:13
MethodselectByAccountAndPwd
()
intercept/src/test/java/com/differ/UserBizTest.java:40
MethodselectById
(int id)
intercept/src/main/java/com/differ/service/impl/UserBiz.java:22
MethodselectHttpResultById
(int id)
intercept/src/main/java/com/differ/repository/mapper/HttpResultMapper.java:9
MethodselectHttpServiceEntityById
(long id)
intercept/src/main/java/com/differ/repository/mapper/HttpServiceEntityMapper.java:12
MethodselectTableRelationById
(int id)
intercept/src/main/java/com/differ/repository/mapper/TableRelationMapper.java:10
MethodsendMessage
(Message message)
compare/src/main/java/com/differ/compare/service/debezium/MessageService.java:6
MethodsendMessage
(Message message)
compare/src/main/java/com/differ/compare/service/debezium/impl/MessageServiceImpl.java:17
MethodsendMessage
(Message message)
MySQL-Debezium/src/main/java/com/ryan/debezium/service/impl/MessageServiceImpl.java:13
MethodsendRequestWithResponse
(Request request)
intercept/src/main/java/com/differ/utils/OkHttpClientWrapper.java:138
MethodsendWebSocketMessage
(WebSocket webSocket, String message, Runnable onMessageReceived)
intercept/src/main/java/com/differ/utils/OkHttpClientWrapper.java:240
MethodsetChangeEventConfig
(ChangeEventHandler changeEventHandler)
DebeziumTest/src/main/java/com/debeziumtest/config/DebeziumConfig.java:70
MethodsetDatabase
(List<DatabaseData> database)
compare/src/main/java/com/differ/compare/config/MysqlConfig.java:21
MethodsetDatabase
(List<DatabaseData> database)
MySQL-Debezium/src/main/java/com/ryan/debezium/config/MysqlConfig.java:22
MethodsetDatabases
(List<DatabaseTableConfig> databases)
compare/src/main/java/com/differ/compare/config/BinlogConfig.java:17
MethodsetDatacenterId
(long id)
intercept/src/main/java/com/differ/utils/SnowflakeIdUtil.java:61
MethodsetHttpService
(@Nullable @RequestBody(required = false) String requestBody, HttpServletRequest request)
intercept/src/main/java/com/differ/controller/HttpController.java:27
MethodsetHttpService
(String serviceString)
intercept/src/main/java/com/differ/service/impl/HttpServiceImpl.java:55
MethodsetHttpService
()
DebeziumTest/src/main/java/com/debeziumtest/controller/HttpResultController.java:16
MethodsetInject
(ChangeDtoRepository changeDtoMapper, ColumnInfoRepository columnInfoRepository,
compare/src/main/java/com/differ/compare/utils/RedisDataSyncUtils.java:58
MethodsetInject
(DBChangeServiceImpl dbChangeService, ParamValidationServiceImpl paramValidationService)
compare/src/main/java/com/differ/compare/controller/result/ChangeController.java:27
MethodsetInject
(ChangeDtoRepository changeDtoMapper)
compare/src/main/java/com/differ/compare/service/impl/DBChangeServiceImpl.java:48
MethodsetInject
(DatabaseInfoRepository databaseInfoRepository, TableInfoRepository tableInfoRepository, ColumnInfoRepository
compare/src/main/java/com/differ/compare/service/db/DatabaseLoaderService.java:30
MethodsetInject
(@Qualifier("writeApi") WriteApiBlocking writeApiBlocking, @Qualifier("influxDBClient") InfluxDBClient influxD
compare/src/main/java/com/differ/compare/repository/influxdb/InfluxDBRepository.java:31
MethodsetInject
(ChangeDtoRepository changeDtoMapper, InfluxDBRepository influxDBRepository)
compare/src/main/java/com/differ/compare/listener/CanalRabbitMQListener.java:43
MethodsetInjections
(InfluxDBClient influxDBClient)
compare/src/main/java/com/differ/compare/service/influxdb/InfluxDbInitializer.java:26
MethodsetMyDependency
(GlobalDispatcherMap globalDispatcherMap, HttpResultMapper httpResultMapper, HttpServiceEntityMapper httpServi
intercept/src/main/java/com/differ/service/impl/HttpServiceImpl.java:48
MethodsetNonNullParameter
(PreparedStatement ps, int i, RequestType parameter, JdbcType jdbcType)
intercept/src/main/java/com/differ/entity/handler/typehandler/RequestTypeHandler.java:20
MethodsetNonNullParameter
(PreparedStatement ps, int i, Map<String, String> parameter, JdbcType jdbcType)
intercept/src/main/java/com/differ/entity/handler/typehandler/MapTypeHandler.java:20
MethodsetNonNullParameter
(PreparedStatement ps, int i, BodyType parameter, JdbcType jdbcType)
intercept/src/main/java/com/differ/entity/handler/typehandler/BodyTypeHandler.java:20
MethodsetNonNullParameter
(PreparedStatement ps, int i, ServiceType parameter, JdbcType jdbcType)
intercept/src/main/java/com/differ/entity/handler/typehandler/ServiceTypeHandler.java:20
MethodsetNonNullParameter
(PreparedStatement ps, int i, List parameter, JdbcType jdbcType)
compare/src/main/java/com/differ/compare/entity/handler/ListTypeHandler.java:24
MethodsetNonNullParameter
(PreparedStatement ps, int i, ServiceType parameter, JdbcType jdbcType)
compare/src/main/java/com/differ/compare/entity/handler/typehandler/ServiceTypeHandler.java:20
MethodsetService
(@RequestBody(required = false) String requestBody, HttpServletRequest request)
intercept/src/main/java/com/differ/controller/HttpReciveController.java:24
MethodsetService
(@RequestBody(required = false) String requestBody, HttpServletRequest request)
intercept/src/main/java/com/differ/controller/HttpController.java:38
MethodsetStrategy
(DebeziumStrategy debeziumStrategy, CanalStrategy canalStrategy, DirectStrategy directStrategy)
compare/src/main/java/com/differ/compare/config/StrategyConfig.java:25
MethodsetWorkerId
(long id)
intercept/src/main/java/com/differ/utils/SnowflakeIdUtil.java:54
MethodsqlServerTimelyExecutor
实例化sql server 实时同步服务类,执行任务 @param configuration @return
DebeziumTest/src/main/java/com/debeziumtest/config/DebeziumConfig.java:261
MethodsqlSessionFactory
()
compare/src/main/java/com/differ/compare/config/MyBatisConfig.java:24
Methodstart
()
DebeziumTest/src/main/java/com/debeziumtest/config/DebeziumConfig.java:282
Methodstart
()
DebeziumTest/src/main/java/com/debeziumtest/entity/DebeziumServerBootstrap.java:22
Methodstart
()
compare/src/main/java/com/differ/compare/listener/DebeziumListener.java:68
Methodstart
()
MySQL-Debezium/src/main/java/com/ryan/debezium/listener/MysqlListener.java:65
Methodstop
()
DebeziumTest/src/main/java/com/debeziumtest/config/DebeziumConfig.java:288
Methodstop
()
DebeziumTest/src/main/java/com/debeziumtest/entity/DebeziumServerBootstrap.java:26
Methodstop
()
compare/src/main/java/com/differ/compare/listener/DebeziumListener.java:75
Methodstop
()
MySQL-Debezium/src/main/java/com/ryan/debezium/listener/MysqlListener.java:72
MethodstrategyContext
()
compare/src/main/java/com/differ/compare/config/StrategyConfig.java:31
MethodtableList
()
compare/src/main/java/com/differ/compare/config/MysqlConfig.java:26
MethodtableList
()
MySQL-Debezium/src/main/java/com/ryan/debezium/config/MysqlConfig.java:26
MethodtestChangeDtoCacheService
()
compare/src/test/java/com/differ/compare/ListCacheServiceTest.java:25
MethodtestColumnInfoOperations
()
compare/src/test/java/com/differ/compare/DatabaseInfoRepositoryTest.java:128
MethodtestDatabaseInfoOperations
()
compare/src/test/java/com/differ/compare/DatabaseInfoRepositoryTest.java:34
MethodtestGetUser
()
intercept/src/test/java/com/differ/MybatisTest.java:28
MethodtestInfluxDB
()
compare/src/test/java/com/differ/compare/InfluxDBTest.java:23
MethodtestLoadDatabaseInfo
()
intercept/src/test/java/com/differ/DatabaseLoaderServiceTest.java:20
← previousnext →301–400 of 422, ranked by callers