mycat Mysql8.0

【实例简介】
特别重要，非常重要的提示：阅读version.txt,我已经做了说明，忘记修改一个地方了。<schema name="monthdatadb" checkSQLschema="true" sqlMaxLimit="100"> checkSQLschema="true" 这个必须修改成true
【实例截图】
【核心代码】
Mycat-Server-1.6
└── Mycat-Server-1.6
├── catlet
│   └── readme.txt
├── conf
│   └── dnindex.properties
├── Dockerfile
├── eclipse-java-google-style.xml
├── intellij-java-google-style.xml
├── LICENSE
├── logs
│   └── 2018-08
│   ├── mycat-08-04-1.log.gz
│   ├── mycat-08-04-2.log.gz
│   ├── mycat-08-04-3.log.gz
│   ├── mycat-08-04-4.log.gz
│   ├── mycat-08-04-5.log.gz
│   ├── mycat-08-04-6.log.gz
│   ├── mycat-08-04-7.log.gz
│   ├── mycat-08-06-1.log.gz
│   ├── mycat-08-06-2.log.gz
│   ├── mycat-08-06-3.log.gz
│   ├── mycat-08-06-4.log.gz
│   ├── mycat-08-06-5.log.gz
│   ├── mycat-08-06-6.log.gz
│   ├── mycat-08-06-7.log.gz
│   ├── mycat-08-08-1.log.gz
│   ├── mycat-08-08-2.log.gz
│   ├── mycat-08-08-3.log.gz
│   ├── mycat-08-08-4.log.gz
│   ├── mycat-08-08-5.log.gz
│   ├── mycat-08-08-6.log.gz
│   ├── mycat-08-08-7.log.gz
│   ├── mycat-08-09-1.log.gz
│   ├── mycat-08-09-2.log.gz
│   ├── mycat-08-09-3.log.gz
│   ├── mycat-08-09-4.log.gz
│   ├── mycat-08-09-5.log.gz
│   ├── mycat-08-09-6.log.gz
│   ├── mycat-08-09-7.log.gz
│   ├── mycat-08-10-1.log.gz
│   ├── mycat-08-10-2.log.gz
│   ├── mycat-08-10-3.log.gz
│   ├── mycat-08-10-4.log.gz
│   ├── mycat-08-10-5.log.gz
│   ├── mycat-08-10-6.log.gz
│   └── mycat-08-10-7.log.gz
├── Mycat-server.iml
├── pom.xml
├── README_Chinese.md
├── README.md
├── src
│   ├── main
│   │   ├── assembly
│   │   │   ├── assembly-linux.xml
│   │   │   ├── assembly-mac.xml
│   │   │   ├── assembly-solaris.xml
│   │   │   ├── assembly-testtool.xml
│   │   │   ├── assembly-unix.xml
│   │   │   ├── assembly-win.xml
│   │   │   ├── bin
│   │   │   │   ├── dataMigrate.bat
│   │   │   │   ├── dataMigrate.sh
│   │   │   │   ├── init_zk_data.bat
│   │   │   │   ├── init_zk_data.sh
│   │   │   │   ├── rehash.sh
│   │   │   │   ├── startup_nowrap.bat
│   │   │   │   └── startup_nowrap.sh
│   │   │   ├── conf
│   │   │   │   └── log4j2.xml
│   │   │   └── testtool
│   │   │   ├── test_globalseq_insert_perf.bat
│   │   │   ├── test_globaltable_insert_perf.bat
│   │   │   ├── test_globaltable_insert_perf.sh
│   │   │   ├── test_stand_insert_perf.bat
│   │   │   ├── test_stand_insert_perf.sh
│   │   │   ├── test_stand_merge_sel_perf.bat
│   │   │   ├── test_stand_merge_sel_perf.sh
│   │   │   ├── test_stand_select_perf.bat
│   │   │   ├── test_stand_select_perf.sh
│   │   │   ├── test_stand_update_perf.bat
│   │   │   └── test_stand_update_perf.sh
│   │   ├── java
│   │   │   └── io
│   │   │   └── mycat
│   │   │   ├── backend
│   │   │   │   ├── BackendConnection.java
│   │   │   │   ├── ConMap.java
│   │   │   │   ├── ConnectionMeta.java
│   │   │   │   ├── ConQueue.java
│   │   │   │   ├── datasource
│   │   │   │   │   ├── PhysicalDatasource.java
│   │   │   │   │   ├── PhysicalDBNode.java
│   │   │   │   │   └── PhysicalDBPool.java
│   │   │   │   ├── heartbeat
│   │   │   │   │   ├── ConsistenCollectHandler.java
│   │   │   │   │   ├── DBHeartbeat.java
│   │   │   │   │   ├── MySQLConsistencyCheckerHandler.java
│   │   │   │   │   ├── MySQLConsistencyChecker.java
│   │   │   │   │   ├── MySQLConsistencyHelper.java
│   │   │   │   │   ├── MySQLDetector.java
│   │   │   │   │   ├── MySQLHeartbeat.java
│   │   │   │   │   └── zkprocess
│   │   │   │   │   ├── ManageHeartBeatChange.java
│   │   │   │   │   ├── MycatLeaderLatch.java
│   │   │   │   │   └── SwitchStatueToZK.java
│   │   │   │   ├── jdbc
│   │   │   │   │   ├── JDBCConnection.java
│   │   │   │   │   ├── JDBCDatasource.java
│   │   │   │   │   ├── JDBCHeartbeat.java
│   │   │   │   │   ├── mongodb
│   │   │   │   │   │   ├── DriverPropertyInfoHelper.java
│   │   │   │   │   │   ├── MongoClientPropertyHelper.java
│   │   │   │   │   │   ├── MongoConnection.java
│   │   │   │   │   │   ├── MongoData.java
│   │   │   │   │   │   ├── MongoDriver.java
│   │   │   │   │   │   ├── MongoEmbeddedObjectProcessor.java
│   │   │   │   │   │   ├── MongoPreparedStatement.java
│   │   │   │   │   │   ├── MongoResultSet.java
│   │   │   │   │   │   ├── MongoResultSetMetaData.java
│   │   │   │   │   │   ├── MongoSQLException.java
│   │   │   │   │   │   ├── MongoSQLParser.java
│   │   │   │   │   │   ├── MongoStatement.java
│   │   │   │   │   │   └── StringUtils.java
│   │   │   │   │   ├── sequoiadb
│   │   │   │   │   │   ├── DriverPropertyInfoHelper.java
│   │   │   │   │   │   ├── SequoiaConnection.java
│   │   │   │   │   │   ├── SequoiaData.java
│   │   │   │   │   │   ├── SequoiaDriver.java
│   │   │   │   │   │   ├── SequoiaPreparedStatement.java
│   │   │   │   │   │   ├── SequoiaResultSet.java
│   │   │   │   │   │   ├── SequoiaResultSetMetaData.java
│   │   │   │   │   │   ├── SequoiaSQLException.java
│   │   │   │   │   │   ├── SequoiaSQLParser.java
│   │   │   │   │   │   ├── SequoiaStatement.java
│   │   │   │   │   │   └── StringUtils.java
│   │   │   │   │   └── ShowVariables.java
│   │   │   │   ├── mysql
│   │   │   │   │   ├── BindValue.java
│   │   │   │   │   ├── BindValueUtil.java
│   │   │   │   │   ├── BufferUtil.java
│   │   │   │   │   ├── ByteUtil.java
│   │   │   │   │   ├── CharsetUtil.java
│   │   │   │   │   ├── DataType.java
│   │   │   │   │   ├── LoadDataUtil.java
│   │   │   │   │   ├── MySQLMessage.java
│   │   │   │   │   ├── nio
│   │   │   │   │   │   ├── handler
│   │   │   │   │   │   │   ├── CommitNodeHandler.java
│   │   │   │   │   │   │   ├── ConnectionHeartBeatHandler.java
│   │   │   │   │   │   │   ├── DelegateResponseHandler.java
│   │   │   │   │   │   │   ├── FetchStoreNodeOfChildTableHandler.java
│   │   │   │   │   │   │   ├── GetConnectionHandler.java
│   │   │   │   │   │   │   ├── KillConnectionHandler.java
│   │   │   │   │   │   │   ├── LoadDataResponseHandler.java
│   │   │   │   │   │   │   ├── LockTablesHandler.java
│   │   │   │   │   │   │   ├── MiddlerQueryResultHandler.java
│   │   │   │   │   │   │   ├── MiddlerResultHandler.java
│   │   │   │   │   │   │   ├── MultiNodeCoordinator.java
│   │   │   │   │   │   │   ├── MultiNodeHandler.java
│   │   │   │   │   │   │   ├── MultiNodeQueryHandler.java
│   │   │   │   │   │   │   ├── NewConnectionRespHandler.java
│   │   │   │   │   │   │   ├── ResponseHandler.java
│   │   │   │   │   │   │   ├── RollbackNodeHandler.java
│   │   │   │   │   │   │   ├── RollbackReleaseHandler.java
│   │   │   │   │   │   │   ├── SecondHandler.java
│   │   │   │   │   │   │   ├── SecondQueryHandler.java
│   │   │   │   │   │   │   ├── SimpleLogHandler.java
│   │   │   │   │   │   │   ├── SingleNodeHandler.java
│   │   │   │   │   │   │   ├── Terminatable.java
│   │   │   │   │   │   │   └── UnLockTablesHandler.java
│   │   │   │   │   │   ├── MySQLConnectionAuthenticator.java
│   │   │   │   │   │   ├── MySQLConnectionFactory.java
│   │   │   │   │   │   ├── MySQLConnectionHandler.java
│   │   │   │   │   │   ├── MySQLConnection.java
│   │   │   │   │   │   └── MySQLDataSource.java
│   │   │   │   │   ├── PacketUtil.java
│   │   │   │   │   ├── PreparedStatement.java
│   │   │   │   │   ├── SecurityUtil.java
│   │   │   │   │   ├── StreamUtil.java
│   │   │   │   │   └── xa
│   │   │   │   │   ├── CoordinatorLogEntry.java
│   │   │   │   │   ├── Deserializer.java
│   │   │   │   │   ├── LogFileLock.java
│   │   │   │   │   ├── ParticipantLogEntry.java
│   │   │   │   │   ├── recovery
│   │   │   │   │   │   ├── DeserialisationException.java
│   │   │   │   │   │   ├── impl
│   │   │   │   │   │   │   ├── FileSystemRepository.java
│   │   │   │   │   │   │   └── InMemoryRepository.java
│   │   │   │   │   │   ├── LogException.java
│   │   │   │   │   │   ├── LogReadException.java
│   │   │   │   │   │   ├── LogWriteException.java
│   │   │   │   │   │   └── Repository.java
│   │   │   │   │   ├── Serializer.java
│   │   │   │   │   ├── TxState.java
│   │   │   │   │   ├── VersionedFile.java
│   │   │   │   │   └── XARollbackCallback.java
│   │   │   │   └── postgresql
│   │   │   │   ├── heartbeat
│   │   │   │   │   ├── PostgreSQLDetector.java
│   │   │   │   │   └── PostgreSQLHeartbeat.java
│   │   │   │   ├── package-info.java
│   │   │   │   ├── packet
│   │   │   │   │   ├── AuthenticationPacket.java
│   │   │   │   │   ├── BackendKeyData.java
│   │   │   │   │   ├── BindComplete.java
│   │   │   │   │   ├── Bind.java
│   │   │   │   │   ├── CancelRequest.java
│   │   │   │   │   ├── CommandComplete.java
│   │   │   │   │   ├── CopyInResponse.java
│   │   │   │   │   ├── CopyOutResponse.java
│   │   │   │   │   ├── DataRow.java
│   │   │   │   │   ├── EmptyQueryResponse.java
│   │   │   │   │   ├── ErrorResponse.java
│   │   │   │   │   ├── NoticeResponse.java
│   │   │   │   │   ├── NotificationResponse.java
│   │   │   │   │   ├── ParameterDescription.java
│   │   │   │   │   ├── ParameterStatus.java
│   │   │   │   │   ├── ParseComplete.java
│   │   │   │   │   ├── Parse.java
│   │   │   │   │   ├── PasswordMessage.java
│   │   │   │   │   ├── PostgreSQLPacket.java
│   │   │   │   │   ├── Query.java
│   │   │   │   │   ├── ReadyForQuery.java
│   │   │   │   │   ├── RowDescription.java
│   │   │   │   │   ├── SSLRequest.java
│   │   │   │   │   ├── StartupMessage.java
│   │   │   │   │   └── Terminate.java
│   │   │   │   ├── PostgreSQLBackendConnectionFactory.java
│   │   │   │   ├── PostgreSQLBackendConnectionHandler.java
│   │   │   │   ├── PostgreSQLBackendConnection.java
│   │   │   │   ├── PostgreSQLDataSource.java
│   │   │   │   └── utils
│   │   │   │   ├── MD5Digest.java
│   │   │   │   ├── PacketUtils.java
│   │   │   │   ├── PgPacketApaterUtils.java
│   │   │   │   ├── PgSqlApaterUtils.java
│   │   │   │   └── PIOUtils.java
│   │   │   ├── buffer
│   │   │   │   ├── BufferArray.java
│   │   │   │   ├── BufferPool.java
│   │   │   │   ├── ByteBufferArena.java
│   │   │   │   ├── ByteBufferChunk.java
│   │   │   │   ├── ByteBufferChunkList.java
│   │   │   │   ├── ByteBufferPage.java
│   │   │   │   ├── DirectByteBufferPool.java
│   │   │   │   ├── MyCatMemoryAllocator.java
│   │   │   │   └── NettyBufferPool.java
│   │   │   ├── cache
│   │   │   │   ├── CachePoolFactory.java
│   │   │   │   ├── CachePool.java
│   │   │   │   ├── CacheService.java
│   │   │   │   ├── CacheStatic.java
│   │   │   │   ├── DefaultLayedCachePool.java
│   │   │   │   ├── impl
│   │   │   │   │   ├── EnchachePooFactory.java
│   │   │   │   │   ├── EnchachePool.java
│   │   │   │   │   ├── LevelDBCachePooFactory.java
│   │   │   │   │   ├── LevelDBPool.java
│   │   │   │   │   ├── MapDBCachePooFactory.java
│   │   │   │   │   └── MapDBCachePool.java
│   │   │   │   ├── index
│   │   │   │   │   └── Shard.java
│   │   │   │   ├── LayerCachePool.java
│   │   │   │   ├── MysqlDataSetCache.java
│   │   │   │   └── MysqlDataSetService.java
│   │   │   ├── catlets
│   │   │   │   ├── Catlet.java
│   │   │   │   ├── JoinParser.java
│   │   │   │   ├── ShareJoin.java
│   │   │   │   └── TableFilter.java
│   │   │   ├── config
│   │   │   │   ├── Alarms.java
│   │   │   │   ├── Capabilities.java
│   │   │   │   ├── classloader
│   │   │   │   │   ├── DynaClassLoader.java
│   │   │   │   │   └── JarLoader.java
│   │   │   │   ├── ConfigInitializer.java
│   │   │   │   ├── ErrorCode.java
│   │   │   │   ├── Fields.java
│   │   │   │   ├── Isolations.java
│   │   │   │   ├── loader
│   │   │   │   │   ├── ConfigLoader.java
│   │   │   │   │   ├── console
│   │   │   │   │   │   └── ZookeeperPath.java
│   │   │   │   │   ├── SchemaLoader.java
│   │   │   │   │   ├── xml
│   │   │   │   │   │   ├── XMLConfigLoader.java
│   │   │   │   │   │   ├── XMLRuleLoader.java
│   │   │   │   │   │   ├── XMLSchemaLoader.java
│   │   │   │   │   │   └── XMLServerLoader.java
│   │   │   │   │   └── zkprocess
│   │   │   │   │   ├── comm
│   │   │   │   │   │   ├── NotiflyService.java
│   │   │   │   │   │   ├── ZkConfig.java
│   │   │   │   │   │   ├── ZkParamCfg.java
│   │   │   │   │   │   └── ZookeeperProcessListen.java
│   │   │   │   │   ├── console
│   │   │   │   │   │   ├── ParseParamEnum.java
│   │   │   │   │   │   └── ZkNofiflyCfg.java
│   │   │   │   │   ├── entity
│   │   │   │   │   │   ├── cache
│   │   │   │   │   │   │   ├── CacheInfo.java
│   │   │   │   │   │   │   └── Ehcache.java
│   │   │   │   │   │   ├── Named.java
│   │   │   │   │   │   ├── package-info.java
│   │   │   │   │   │   ├── Propertied.java
│   │   │   │   │   │   ├── Property.java
│   │   │   │   │   │   ├── rule
│   │   │   │   │   │   │   ├── function
│   │   │   │   │   │   │   │   └── Function.java
│   │   │   │   │   │   │   └── tablerule
│   │   │   │   │   │   │   ├── Rule.java
│   │   │   │   │   │   │   └── TableRule.java
│   │   │   │   │   │   ├── Rules.java
│   │   │   │   │   │   ├── schema
│   │   │   │   │   │   │   ├── datahost
│   │   │   │   │   │   │   │   ├── DataHost.java
│   │   │   │   │   │   │   │   ├── ReadHost.java
│   │   │   │   │   │   │   │   └── WriteHost.java
│   │   │   │   │   │   │   ├── datanode
│   │   │   │   │   │   │   │   └── DataNode.java
│   │   │   │   │   │   │   └── schema
│   │   │   │   │   │   │   ├── ChildTable.java
│   │   │   │   │   │   │   ├── Schema.java
│   │   │   │   │   │   │   └── Table.java
│   │   │   │   │   │   ├── Schemas.java
│   │   │   │   │   │   ├── server
│   │   │   │   │   │   │   ├── System.java
│   │   │   │   │   │   │   └── user
│   │   │   │   │   │   │   └── User.java
│   │   │   │   │   │   └── Server.java
│   │   │   │   │   ├── parse
│   │   │   │   │   │   ├── entryparse
│   │   │   │   │   │   │   ├── cache
│   │   │   │   │   │   │   │   ├── json
│   │   │   │   │   │   │   │   │   └── EhcacheJsonParse.java
│   │   │   │   │   │   │   │   └── xml
│   │   │   │   │   │   │   │   └── EhcacheParseXmlImpl.java
│   │   │   │   │   │   │   ├── rule
│   │   │   │   │   │   │   │   ├── json
│   │   │   │   │   │   │   │   │   ├── FunctionJsonParse.java
│   │   │   │   │   │   │   │   │   └── TableRuleJsonParse.java
│   │   │   │   │   │   │   │   └── xml
│   │   │   │   │   │   │   │   └── RuleParseXmlImpl.java
│   │   │   │   │   │   │   ├── schema
│   │   │   │   │   │   │   │   ├── json
│   │   │   │   │   │   │   │   │   ├── DataHostJsonParse.java
│   │   │   │   │   │   │   │   │   ├── DataNodeJsonParse.java
│   │   │   │   │   │   │   │   │   └── SchemaJsonParse.java
│   │   │   │   │   │   │   │   └── xml
│   │   │   │   │   │   │   │   └── SchemasParseXmlImpl.java
│   │   │   │   │   │   │   └── server
│   │   │   │   │   │   │   ├── json
│   │   │   │   │   │   │   │   ├── SystemJsonParse.java
│   │   │   │   │   │   │   │   └── UserJsonParse.java
│   │   │   │   │   │   │   └── xml
│   │   │   │   │   │   │   └── ServerParseXmlImpl.java
│   │   │   │   │   │   ├── JsonProcessBase.java
│   │   │   │   │   │   ├── ParseJsonServiceInf.java
│   │   │   │   │   │   ├── ParseXmlServiceInf.java
│   │   │   │   │   │   └── XmlProcessBase.java
│   │   │   │   │   ├── xmltozk
│   │   │   │   │   │   ├── BindataToZK.java
│   │   │   │   │   │   ├── listen
│   │   │   │   │   │   │   ├── EcachesxmlTozkLoader.java
│   │   │   │   │   │   │   ├── OthermsgTozkLoader.java
│   │   │   │   │   │   │   ├── RulesxmlTozkLoader.java
│   │   │   │   │   │   │   ├── SchemasxmlTozkLoader.java
│   │   │   │   │   │   │   ├── SequenceTozkLoader.java
│   │   │   │   │   │   │   └── ServerxmlTozkLoader.java
│   │   │   │   │   │   └── XmltoZkMain.java
│   │   │   │   │   ├── zktoxml
│   │   │   │   │   │   ├── command
│   │   │   │   │   │   │   └── CommandPathListener.java
│   │   │   │   │   │   ├── listen
│   │   │   │   │   │   │   ├── BinDataPathChildrenCacheListener.java
│   │   │   │   │   │   │   ├── EcacheszkToxmlLoader.java
│   │   │   │   │   │   │   ├── RuleDataPathChildrenCacheListener.java
│   │   │   │   │   │   │   ├── RuleFunctionCacheListener.java
│   │   │   │   │   │   │   ├── RuleszkToxmlLoader.java
│   │   │   │   │   │   │   ├── SchemaszkToxmlLoader.java
│   │   │   │   │   │   │   ├── SequenceTopropertiesLoader.java
│   │   │   │   │   │   │   └── ServerzkToxmlLoader.java
│   │   │   │   │   │   └── ZktoXmlMain.java
│   │   │   │   │   └── zookeeper
│   │   │   │   │   ├── ClusterInfo.java
│   │   │   │   │   ├── DataInf.java
│   │   │   │   │   ├── DiretoryInf.java
│   │   │   │   │   └── process
│   │   │   │   │   ├── ZkDataImpl.java
│   │   │   │   │   ├── ZkDirectoryImpl.java
│   │   │   │   │   └── ZkMultLoader.java
│   │   │   │   ├── model
│   │   │   │   │   ├── ClusterConfig.java
│   │   │   │   │   ├── DataHostConfig.java
│   │   │   │   │   ├── DataNodeConfig.java
│   │   │   │   │   ├── DBHostConfig.java
│   │   │   │   │   ├── FirewallConfig.java
│   │   │   │   │   ├── MycatNodeConfig.java
│   │   │   │   │   ├── rule
│   │   │   │   │   │   ├── RuleAlgorithm.java
│   │   │   │   │   │   ├── RuleConfig.java
│   │   │   │   │   │   └── TableRuleConfig.java
│   │   │   │   │   ├── SchemaConfig.java
│   │   │   │   │   ├── SystemConfig.java
│   │   │   │   │   ├── TableConfig.java
│   │   │   │   │   ├── TableConfigMap.java
│   │   │   │   │   ├── TableRuleConfig.java
│   │   │   │   │   ├── UserConfig.java
│   │   │   │   │   └── UserPrivilegesConfig.java
│   │   │   │   ├── MycatCluster.java
│   │   │   │   ├── MycatConfig.java
│   │   │   │   ├── MycatNode.java
│   │   │   │   ├── MycatPrivileges.java
│   │   │   │   ├── table
│   │   │   │   │   └── structure
│   │   │   │   │   ├── MySQLTableStructureDetector.java
│   │   │   │   │   └── TableStructureProcessor.java
│   │   │   │   ├── util
│   │   │   │   │   ├── BeanConfig.java
│   │   │   │   │   ├── ConfigException.java
│   │   │   │   │   ├── ConfigUtil.java
│   │   │   │   │   ├── DnPropertyUtil.java
│   │   │   │   │   ├── FieldDictionary.java
│   │   │   │   │   ├── Initializable.java
│   │   │   │   │   ├── JVMInfo.java
│   │   │   │   │   ├── ObjectAccessException.java
│   │   │   │   │   ├── OrderRetainingMap.java
│   │   │   │   │   ├── ParameterMapping.java
│   │   │   │   │   ├── ReflectionProvider.java
│   │   │   │   │   └── Visitor.java
│   │   │   │   ├── Versions.java
│   │   │   │   └── Versions.template
│   │   │   ├── manager
│   │   │   │   ├── handler
│   │   │   │   │   ├── ClearHandler.java
│   │   │   │   │   ├── ConfFileHandler.java
│   │   │   │   │   ├── ReloadHandler.java
│   │   │   │   │   ├── RollbackHandler.java
│   │   │   │   │   ├── SelectHandler.java
│   │   │   │   │   ├── ShowHandler.java
│   │   │   │   │   ├── ShowServerLog.java
│   │   │   │   │   ├── StopHandler.java
│   │   │   │   │   ├── SwitchHandler.java
│   │   │   │   │   └── ZKHandler.java
│   │   │   │   ├── ManagerConnectionFactory.java
│   │   │   │   ├── ManagerConnection.java
│   │   │   │   ├── ManagerQueryHandler.java
│   │   │   │   └── response
│   │   │   │   ├── CheckGlobalTable.java
│   │   │   │   ├── ClearSlow.java
│   │   │   │   ├── KillConnection.java
│   │   │   │   ├── Offline.java
│   │   │   │   ├── Online.java
│   │   │   │   ├── ReloadConfig.java
│   │   │   │   ├── ReloadQueryCf.java
│   │   │   │   ├── ReloadSqlSlowTime.java
│   │   │   │   ├── ReloadUser.java
│   │   │   │   ├── ReloadUserStat.java
│   │   │   │   ├── ReloadZktoXml.java
│   │   │   │   ├── RollbackConfig.java
│   │   │   │   ├── RollbackUser.java
│   │   │   │   ├── SelectSessionAutoIncrement.java
│   │   │   │   ├── SelectSessionTxReadOnly.java
│   │   │   │   ├── SelectVersionComment.java
│   │   │   │   ├── ShowBackend.java
│   │   │   │   ├── ShowBackendOld.java
│   │   │   │   ├── ShowCollation.java
│   │   │   │   ├── ShowCommand.java
│   │   │   │   ├── ShowConnection.java
│   │   │   │   ├── ShowConnectionSQL.java
│   │   │   │   ├── ShowDatabase.java
│   │   │   │   ├── ShowDataNode.java
│   │   │   │   ├── ShowDatasourceCluster.java
│   │   │   │   ├── ShowDataSource.java
│   │   │   │   ├── ShowDatasourceSynDetail.java
│   │   │   │   ├── ShowDatasourceSyn.java
│   │   │   │   ├── ShowDirectMemory.java
│   │   │   │   ├── ShowHeartbeatDetail.java
│   │   │   │   ├── ShowHeartbeat.java
│   │   │   │   ├── ShowHelp.java
│   │   │   │   ├── ShowParser.java
│   │   │   │   ├── ShowProcessor.java
│   │   │   │   ├── ShowRouter.java
│   │   │   │   ├── ShowServer.java
│   │   │   │   ├── ShowSession.java
│   │   │   │   ├── ShowSQLCondition.java
│   │   │   │   ├── ShowSQLDetail.java
│   │   │   │   ├── ShowSQLExecute.java
│   │   │   │   ├── ShowSQLHigh.java
│   │   │   │   ├── ShowSQL.java
│   │   │   │   ├── ShowSQLLarge.java
│   │   │   │   ├── ShowSqlResultSet.java
│   │   │   │   ├── ShowSQLSlow.java
│   │   │   │   ├── ShowSQLSumTable.java
│   │   │   │   ├── ShowSQLSumUser.java
│   │   │   │   ├── ShowSysLog.java
│   │   │   │   ├── ShowSysParam.java
│   │   │   │   ├── ShowThreadPool.java
│   │   │   │   ├── ShowTime.java
│   │   │   │   ├── ShowVariables.java
│   │   │   │   ├── ShowVersion.java
│   │   │   │   ├── ShowWhiteHost.java
│   │   │   │   ├── StopHeartbeat.java
│   │   │   │   └── SwitchDataSource.java
│   │   │   ├── memory
│   │   │   │   ├── environment
│   │   │   │   │   ├── EnvironmentInformation.java
│   │   │   │   │   ├── HardwareDescription.java
│   │   │   │   │   ├── Hardware.java
│   │   │   │   │   └── OperatingSystem.java
│   │   │   │   ├── MyCatMemory.java
│   │   │   │   └── unsafe
│   │   │   │   ├── array
│   │   │   │   │   ├── ByteArrayMethods.java
│   │   │   │   │   ├── CharArray.java
│   │   │   │   │   └── LongArray.java
│   │   │   │   ├── bitset
│   │   │   │   │   └── BitSetMethods.java
│   │   │   │   ├── hash
│   │   │   │   │   └── Murmur3_x86_32.java
│   │   │   │   ├── KVIterator.java
│   │   │   │   ├── map
│   │   │   │   │   ├── BytesToBytesMap.java
│   │   │   │   │   ├── HashMapGrowthStrategy.java
│   │   │   │   │   └── UnsafeFixedWidthAggregationMap.java
│   │   │   │   ├── memory
│   │   │   │   │   ├── HeapMemoryAllocator.java
│   │   │   │   │   ├── MemoryAllocator.java
│   │   │   │   │   ├── MemoryBlock.java
│   │   │   │   │   ├── MemoryLocation.java
│   │   │   │   │   ├── mm
│   │   │   │   │   │   ├── DataNodeMemoryManager.java
│   │   │   │   │   │   ├── MemoryConsumer.java
│   │   │   │   │   │   ├── MemoryManager.java
│   │   │   │   │   │   ├── MemoryMode.java
│   │   │   │   │   │   ├── MemoryPool.java
│   │   │   │   │   │   ├── ResultMergeMemoryManager.java
│   │   │   │   │   │   └── ResultSetMemoryPool.java
│   │   │   │   │   └── UnsafeMemoryAllocator.java
│   │   │   │   ├── Platform.java
│   │   │   │   ├── ringbuffer
│   │   │   │   │   ├── common
│   │   │   │   │   │   ├── barrier
│   │   │   │   │   │   │   └── SequenceBarrier.java
│   │   │   │   │   │   ├── Cursored.java
│   │   │   │   │   │   ├── DataProvider.java
│   │   │   │   │   │   ├── event
│   │   │   │   │   │   │   ├── EventFactory.java
│   │   │   │   │   │   │   ├── EventSequencer.java
│   │   │   │   │   │   │   ├── EventSink.java
│   │   │   │   │   │   │   ├── EventTranslator.java
│   │   │   │   │   │   │   ├── EventTranslatorOneArg.java
│   │   │   │   │   │   │   ├── EventTranslatorThreeArg.java
│   │   │   │   │   │   │   ├── EventTranslatorTwoArg.java
│   │   │   │   │   │   │   └── EventTranslatorVararg.java
│   │   │   │   │   │   ├── sequence
│   │   │   │   │   │   │   ├── SequenceGroups.java
│   │   │   │   │   │   │   └── Sequence.java
│   │   │   │   │   │   ├── Sequenced.java
│   │   │   │   │   │   └── waitStrategy
│   │   │   │   │   │   ├── impl
│   │   │   │   │   │   │   ├── BlockingWaitStrategy.java
│   │   │   │   │   │   │   ├── BusySpinWaitStrategy.java
│   │   │   │   │   │   │   └── SleepingWaitStrategy.java
│   │   │   │   │   │   └── WaitStrategy.java
│   │   │   │   │   ├── exception
│   │   │   │   │   │   ├── AlertException.java
│   │   │   │   │   │   ├── InsufficientCapacityException.java
│   │   │   │   │   │   └── TimeoutException.java
│   │   │   │   │   ├── producer
│   │   │   │   │   │   ├── AbstractSequencer.java
│   │   │   │   │   │   ├── MultiProducerSequencer.java
│   │   │   │   │   │   ├── Sequencer.java
│   │   │   │   │   │   └── SingleProducerSequencer.java
│   │   │   │   │   ├── RingBuffer.java
│   │   │   │   │   └── utils
│   │   │   │   │   └── Util.java
│   │   │   │   ├── row
│   │   │   │   │   ├── BufferHolder.java
│   │   │   │   │   ├── StructType.java
│   │   │   │   │   ├── UnsafeRow.java
│   │   │   │   │   └── UnsafeRowWriter.java
│   │   │   │   ├── storage
│   │   │   │   │   ├── ConnectionId.java
│   │   │   │   │   ├── DataNodeDiskManager.java
│   │   │   │   │   ├── DataNodeFileManager.java
│   │   │   │   │   ├── DeserializationStream.java
│   │   │   │   │   ├── DiskRowWriter.java
│   │   │   │   │   ├── DummySerializerInstance.java
│   │   │   │   │   ├── SerializationStream.java
│   │   │   │   │   ├── SerializerInstance.java
│   │   │   │   │   ├── SerializerManager.java
│   │   │   │   │   ├── TempDataNodeId.java
│   │   │   │   │   └── TimeTrackingOutputStream.java
│   │   │   │   ├── types
│   │   │   │   │   ├── ByteArray.java
│   │   │   │   │   ├── CalendarInterval.java
│   │   │   │   │   └── UTF8String.java
│   │   │   │   └── utils
│   │   │   │   ├── BytesTools.java
│   │   │   │   ├── ByteUnit.java
│   │   │   │   ├── JavaUtils.java
│   │   │   │   ├── MycatPropertyConf.java
│   │   │   │   └── sort
│   │   │   │   ├── AbstractScalaRowIterator.java
│   │   │   │   ├── PrefixComparator.java
│   │   │   │   ├── PrefixComparators.java
│   │   │   │   ├── RadixSort.java
│   │   │   │   ├── RecordComparator.java
│   │   │   │   ├── RecordPointerAndKeyPrefix.java
│   │   │   │   ├── RowPrefixComputer.java
│   │   │   │   ├── SortDataFormat.java
│   │   │   │   ├── Sorter.java
│   │   │   │   ├── SortPrefixUtils.java
│   │   │   │   ├── TestSorter.java
│   │   │   │   ├── TimSort.java
│   │   │   │   ├── UnsafeExternalRowSorter.java
│   │   │   │   ├── UnsafeExternalSorter.java
│   │   │   │   ├── UnsafeInMemorySorter.java
│   │   │   │   ├── UnsafeKeyValueSorter.java
│   │   │   │   ├── UnsafeKVExternalSorter.java
│   │   │   │   ├── UnsafeRowsMerger.java
│   │   │   │   ├── UnsafeSortDataFormat.java
│   │   │   │   ├── UnsafeSorterIterator.java
│   │   │   │   ├── UnsafeSorterSpillMerger.java
│   │   │   │   ├── UnsafeSorterSpillReader.java
│   │   │   │   └── UnsafeSorterSpillWriter.java
│   │   │   ├── migrate
│   │   │   │   ├── BinlogIdleCheck.java
│   │   │   │   ├── BinlogStreamHoder.java
│   │   │   │   ├── BinlogStream.java
│   │   │   │   ├── MigrateDumpRunner.java
│   │   │   │   ├── MigrateMainRunner.java
│   │   │   │   ├── MigrateTask.java
│   │   │   │   ├── MigrateTaskWatch.java
│   │   │   │   ├── MigrateUtils.java
│   │   │   │   ├── SqlExecuteListener.java
│   │   │   │   ├── SwitchCleanListener.java
│   │   │   │   ├── SwitchCommitListener.java
│   │   │   │   ├── SwitchPrepareCheckRunner.java
│   │   │   │   ├── SwitchPrepareListener.java
│   │   │   │   ├── TaskNode.java
│   │   │   │   └── TaskStatus.java
│   │   │   ├── MycatServer.java
│   │   │   ├── MycatShutdown.java
│   │   │   ├── MycatStartup.java
│   │   │   ├── net
│   │   │   │   ├── AbstractConnection.java
│   │   │   │   ├── AIOAcceptor.java
│   │   │   │   ├── AIOConnector.java
│   │   │   │   ├── AIOSocketWR.java
│   │   │   │   ├── BackendAIOConnection.java
│   │   │   │   ├── BIOConnection.java
│   │   │   │   ├── ClosableConnection.java
│   │   │   │   ├── ConnectionException.java
│   │   │   │   ├── factory
│   │   │   │   │   ├── BackendConnectionFactory.java
│   │   │   │   │   └── FrontendConnectionFactory.java
│   │   │   │   ├── FrontendConnection.java
│   │   │   │   ├── handler
│   │   │   │   │   ├── BackendAsyncHandler.java
│   │   │   │   │   ├── FrontendAuthenticator.java
│   │   │   │   │   ├── FrontendCommandHandler.java
│   │   │   │   │   ├── FrontendPrepareHandler.java
│   │   │   │   │   ├── FrontendPrivileges.java
│   │   │   │   │   ├── FrontendQueryHandler.java
│   │   │   │   │   └── LoadDataInfileHandler.java
│   │   │   │   ├── mysql
│   │   │   │   │   ├── AuthPacket.java
│   │   │   │   │   ├── BinaryPacket.java
│   │   │   │   │   ├── BinaryRowDataPacket.java
│   │   │   │   │   ├── CommandPacket.java
│   │   │   │   │   ├── EmptyPacket.java
│   │   │   │   │   ├── EOFPacket.java
│   │   │   │   │   ├── ErrorPacket.java
│   │   │   │   │   ├── ExecutePacket.java
│   │   │   │   │   ├── FieldPacket.java
│   │   │   │   │   ├── HandshakePacket.java
│   │   │   │   │   ├── HandshakeV10Packet.java
│   │   │   │   │   ├── HeartbeatPacket.java
│   │   │   │   │   ├── LongDataPacket.java
│   │   │   │   │   ├── MySQLPacket.java
│   │   │   │   │   ├── OkPacket.java
│   │   │   │   │   ├── PingPacket.java
│   │   │   │   │   ├── PreparedOkPacket.java
│   │   │   │   │   ├── QuitPacket.java
│   │   │   │   │   ├── Reply323Packet.java
│   │   │   │   │   ├── RequestFilePacket.java
│   │   │   │   │   ├── ResetPacket.java
│   │   │   │   │   ├── ResultSetHeaderPacket.java
│   │   │   │   │   └── RowDataPacket.java
│   │   │   │   ├── NIOAcceptor.java
│   │   │   │   ├── NIOConnection.java
│   │   │   │   ├── NIOConnector.java
│   │   │   │   ├── NIOHandler.java
│   │   │   │   ├── NIOProcessor.java
│   │   │   │   ├── NIOReactor.java
│   │   │   │   ├── NIOReactorPool.java
│   │   │   │   ├── NIOSocketWR.java
│   │   │   │   ├── postgres
│   │   │   │   │   ├── AuthenticationCleartextPassword.java
│   │   │   │   │   ├── AuthenticationGSSContinue.java
│   │   │   │   │   ├── AuthenticationGSS.java
│   │   │   │   │   ├── AuthenticationKerberosV5.java
│   │   │   │   │   ├── AuthenticationMD5Password.java
│   │   │   │   │   ├── AuthenticationOk.java
│   │   │   │   │   ├── AuthenticationSCMCredential.java
│   │   │   │   │   ├── AuthenticationSSPI.java
│   │   │   │   │   ├── BackendKeyData.java
│   │   │   │   │   ├── BindComplete.java
│   │   │   │   │   ├── Bind.java
│   │   │   │   │   ├── CancelRequest.java
│   │   │   │   │   ├── CloseComplete.java
│   │   │   │   │   ├── Close.java
│   │   │   │   │   ├── CommandComplete.java
│   │   │   │   │   ├── CopyBothResponse.java
│   │   │   │   │   ├── CopyData.java
│   │   │   │   │   ├── CopyDone.java
│   │   │   │   │   ├── CopyFail.java
│   │   │   │   │   ├── CopyInResponse.java
│   │   │   │   │   ├── CopyOutResponse.java
│   │   │   │   │   ├── DataRow.java
│   │   │   │   │   ├── Describe.java
│   │   │   │   │   ├── EmptyQueryResponse.java
│   │   │   │   │   ├── ErrorResponse.java
│   │   │   │   │   ├── Execute.java
│   │   │   │   │   ├── Flush.java
│   │   │   │   │   ├── FunctionCall.java
│   │   │   │   │   ├── FunctionCallResponse.java
│   │   │   │   │   ├── NoData.java
│   │   │   │   │   ├── NoticeResponse.java
│   │   │   │   │   ├── NotificationResponse.java
│   │   │   │   │   ├── ParameterDescription.java
│   │   │   │   │   ├── ParameterStatus.java
│   │   │   │   │   ├── ParseComplete.java
│   │   │   │   │   ├── Parse.java
│   │   │   │   │   ├── PasswordMessage.java
│   │   │   │   │   ├── PortalSuspended.java
│   │   │   │   │   ├── PostgresPacket.java
│   │   │   │   │   ├── Query.java
│   │   │   │   │   ├── ReadyForQuery.java
│   │   │   │   │   ├── RowDescription.java
│   │   │   │   │   ├── SSLRequest.java
│   │   │   │   │   ├── StartupMessage.java
│   │   │   │   │   ├── Sync.java
│   │   │   │   │   └── Terminate.java
│   │   │   │   ├── SocketAcceptor.java
│   │   │   │   ├── SocketConnector.java
│   │   │   │   ├── SocketWR.java
│   │   │   │   └── WriteEventCheckRunner.java
│   │   │   ├── route
│   │   │   │   ├── factory
│   │   │   │   │   └── RouteStrategyFactory.java
│   │   │   │   ├── function
│   │   │   │   │   ├── AbstractPartitionAlgorithm.java
│   │   │   │   │   ├── AutoPartitionByLong.java
│   │   │   │   │   ├── LatestMonthPartion.java
│   │   │   │   │   ├── NumberParseUtil.java
│   │   │   │   │   ├── PartitionByCRC32PreSlot.java
│   │   │   │   │   ├── PartitionByDate.java
│   │   │   │   │   ├── PartitionByFileMap.java
│   │   │   │   │   ├── PartitionByHashMod.java
│   │   │   │   │   ├── PartitionByHotDate.java
│   │   │   │   │   ├── PartitionByJumpConsistentHash.java
│   │   │   │   │   ├── PartitionByLong.java
│   │   │   │   │   ├── PartitionByMod.java
│   │   │   │   │   ├── PartitionByMonthAndHistory.java
│   │   │   │   │   ├── PartitionByMonth.java
│   │   │   │   │   ├── PartitionByMurmurHash.java
│   │   │   │   │   ├── PartitionByPattern.java
│   │   │   │   │   ├── PartitionByPrefixPattern.java
│   │   │   │   │   ├── PartitionByRangeDateHash.java
│   │   │   │   │   ├── PartitionByRangeMod.java
│   │   │   │   │   ├── PartitionByString.java
│   │   │   │   │   ├── PartitionDirectBySubString.java
│   │   │   │   │   ├── PureJavaCrc32.java
│   │   │   │   │   ├── ReloadFunction.java
│   │   │   │   │   ├── SlotFunction.java
│   │   │   │   │   └── TableRuleAware.java
│   │   │   │   ├── handler
│   │   │   │   │   ├── HintCatletHandler.java
│   │   │   │   │   ├── HintDataNodeHandler.java
│   │   │   │   │   ├── HintHandlerFactory.java
│   │   │   │   │   ├── HintHandler.java
│   │   │   │   │   ├── HintMasterDBHandler.java
│   │   │   │   │   ├── HintSchemaHandler.java
│   │   │   │   │   └── HintSQLHandler.java
│   │   │   │   ├── impl
│   │   │   │   │   ├── AbstractRouteStrategy.java
│   │   │   │   │   ├── DruidMycatRouteStrategy.java
│   │   │   │   │   └── middlerResultStrategy
│   │   │   │   │   ├── BinaryOpResultHandler.java
│   │   │   │   │   ├── InSubQueryResultHandler.java
│   │   │   │   │   ├── RouteMiddlerReaultHandler.java
│   │   │   │   │   ├── SQLAllResultHandler.java
│   │   │   │   │   ├── SQLExistsResultHandler.java
│   │   │   │   │   └── SQLQueryResultHandler.java
│   │   │   │   ├── MyCATSequnceProcessor.java
│   │   │   │   ├── parser
│   │   │   │   │   ├── druid
│   │   │   │   │   │   ├── DruidParserFactory.java
│   │   │   │   │   │   ├── DruidParser.java
│   │   │   │   │   │   ├── DruidSequenceHandler.java
│   │   │   │   │   │   ├── DruidShardingParseInfo.java
│   │   │   │   │   │   ├── impl
│   │   │   │   │   │   │   ├── DefaultDruidParser.java
│   │   │   │   │   │   │   ├── DruidAlterTableParser.java
│   │   │   │   │   │   │   ├── DruidCreateTableParser.java
│   │   │   │   │   │   │   ├── DruidDeleteParser.java
│   │   │   │   │   │   │   ├── DruidInsertParser.java
│   │   │   │   │   │   │   ├── DruidLockTableParser.java
│   │   │   │   │   │   │   ├── DruidSelectDb2Parser.java
│   │   │   │   │   │   │   ├── DruidSelectOracleParser.java
│   │   │   │   │   │   │   ├── DruidSelectParser.java
│   │   │   │   │   │   │   ├── DruidSelectPostgresqlParser.java
│   │   │   │   │   │   │   ├── DruidSelectSqlServerParser.java
│   │   │   │   │   │   │   └── DruidUpdateParser.java
│   │   │   │   │   │   ├── LoadDataOutputVisitor.java
│   │   │   │   │   │   ├── LoadDataStatement.java
│   │   │   │   │   │   ├── MycatExprParser.java
│   │   │   │   │   │   ├── MycatLexer.java
│   │   │   │   │   │   ├── MycatSchemaStatVisitor.java
│   │   │   │   │   │   ├── MycatSelectParser.java
│   │   │   │   │   │   ├── MycatStatementParser.java
│   │   │   │   │   │   ├── MycatSubQueryVisitor.java
│   │   │   │   │   │   ├── RouteCalculateUnit.java
│   │   │   │   │   │   ├── SchemaStatVisitorFactory.java
│   │   │   │   │   │   └── WhereUnit.java
│   │   │   │   │   ├── ManagerParseClear.java
│   │   │   │   │   ├── ManagerParseHeartbeat.java
│   │   │   │   │   ├── ManagerParse.java
│   │   │   │   │   ├── ManagerParseKill.java
│   │   │   │   │   ├── ManagerParseReload.java
│   │   │   │   │   ├── ManagerParseRollback.java
│   │   │   │   │   ├── ManagerParseSelect.java
│   │   │   │   │   ├── ManagerParseShow.java
│   │   │   │   │   ├── ManagerParseStop.java
│   │   │   │   │   ├── ManagerParseSwitch.java
│   │   │   │   │   ├── primitive
│   │   │   │   │   │   ├── FunctionParser.java
│   │   │   │   │   │   └── Model
│   │   │   │   │   │   ├── Commons.java
│   │   │   │   │   │   ├── Field.java
│   │   │   │   │   │   ├── Function.java
│   │   │   │   │   │   └── Identifier.java
│   │   │   │   │   └── util
│   │   │   │   │   ├── ArrayUtil.java
│   │   │   │   │   ├── CharTypes.java
│   │   │   │   │   ├── PageSQLUtil.java
│   │   │   │   │   ├── Pair.java
│   │   │   │   │   ├── PairUtil.java
│   │   │   │   │   ├── ParseString.java
│   │   │   │   │   ├── ParseUtil.java
│   │   │   │   │   └── SQLParserUtils.java
│   │   │   │   ├── Procedure.java
│   │   │   │   ├── ProcedureParameter.java
│   │   │   │   ├── RouteCheckRule.java
│   │   │   │   ├── RouteResultset.java
│   │   │   │   ├── RouteResultsetNode.java
│   │   │   │   ├── RouteService.java
│   │   │   │   ├── RouteStrategy.java
│   │   │   │   ├── sequence
│   │   │   │   │   ├── BatchInsertSequence.java
│   │   │   │   │   └── handler
│   │   │   │   │   ├── DistributedSequenceHandler.java
│   │   │   │   │   ├── IncrSequenceBDBHandler.java
│   │   │   │   │   ├── IncrSequenceHandler.java
│   │   │   │   │   ├── IncrSequenceMySQLHandler.java
│   │   │   │   │   ├── IncrSequencePropHandler.java
│   │   │   │   │   ├── IncrSequenceTimeHandler.java
│   │   │   │   │   ├── IncrSequenceZKHandler.java
│   │   │   │   │   ├── SequenceHandler.java
│   │   │   │   │   ├── SnowflakeIdSequenceHandler.java
│   │   │   │   │   └── ThirftClientSequenceHandler.java
│   │   │   │   ├── SessionSQLPair.java
│   │   │   │   ├── SQLMerge.java
│   │   │   │   └── util
│   │   │   │   ├── CacheUtil.java
│   │   │   │   ├── PartitionUtil.java
│   │   │   │   ├── PropertiesUtil.java
│   │   │   │   └── RouterUtil.java
│   │   │   ├── server
│   │   │   │   ├── handler
│   │   │   │   │   ├── BeginHandler.java
│   │   │   │   │   ├── Explain2Handler.java
│   │   │   │   │   ├── ExplainHandler.java
│   │   │   │   │   ├── KillHandler.java
│   │   │   │   │   ├── MigrateHandler.java
│   │   │   │   │   ├── MysqlInformationSchemaHandler.java
│   │   │   │   │   ├── MysqlProcHandler.java
│   │   │   │   │   ├── SavepointHandler.java
│   │   │   │   │   ├── SelectHandler.java
│   │   │   │   │   ├── ServerLoadDataInfileHandler.java
│   │   │   │   │   ├── ServerPrepareHandler.java
│   │   │   │   │   ├── SetHandler.java
│   │   │   │   │   ├── ShowCache.java
│   │   │   │   │   ├── ShowHandler.java
│   │   │   │   │   ├── StartHandler.java
│   │   │   │   │   └── UseHandler.java
│   │   │   │   ├── interceptor
│   │   │   │   │   ├── impl
│   │   │   │   │   │   ├── DefaultSqlInterceptor.java
│   │   │   │   │   │   ├── GlobalTableUtil.java
│   │   │   │   │   │   ├── StatisticsSqlInterceptor.java
│   │   │   │   │   │   └── StatSqlInterceptor.java
│   │   │   │   │   └── SQLInterceptor.java
│   │   │   │   ├── NonBlockingSession.java
│   │   │   │   ├── parser
│   │   │   │   │   ├── ServerParse.java
│   │   │   │   │   ├── ServerParseSelect.java
│   │   │   │   │   ├── ServerParseSet.java
│   │   │   │   │   ├── ServerParseShow.java
│   │   │   │   │   └── ServerParseStart.java
│   │   │   │   ├── response
│   │   │   │   │   ├── CharacterSet.java
│   │   │   │   │   ├── Heartbeat.java
│   │   │   │   │   ├── InformationSchemaProfiling.java
│   │   │   │   │   ├── Ping.java
│   │   │   │   │   ├── PreparedStmtResponse.java
│   │   │   │   │   ├── SelectConnnectID.java
│   │   │   │   │   ├── SelectDatabase.java
│   │   │   │   │   ├── SelectIdentity.java
│   │   │   │   │   ├── SelectLastInsertId.java
│   │   │   │   │   ├── SelectTxReadOnly.java
│   │   │   │   │   ├── SelectUser.java
│   │   │   │   │   ├── SelectVariables.java
│   │   │   │   │   ├── SelectVersionComment.java
│   │   │   │   │   ├── SelectVersion.java
│   │   │   │   │   ├── SessionIncrement.java
│   │   │   │   │   ├── SessionIsolation.java
│   │   │   │   │   ├── ShowCobarCluster.java
│   │   │   │   │   ├── ShowCobarStatus.java
│   │   │   │   │   ├── ShowDatabases.java
│   │   │   │   │   ├── ShowFullTables.java
│   │   │   │   │   ├── ShowMyCATCluster.java
│   │   │   │   │   ├── ShowMyCatStatus.java
│   │   │   │   │   └── ShowTables.java
│   │   │   │   ├── ServerConnectionFactory.java
│   │   │   │   ├── ServerConnection.java
│   │   │   │   ├── ServerQueryHandler.java
│   │   │   │   ├── Session.java
│   │   │   │   ├── sqlcmd
│   │   │   │   │   ├── CommitCommand.java
│   │   │   │   │   ├── SQLCmdConstant.java
│   │   │   │   │   └── SQLCtrlCommand.java
│   │   │   │   └── util
│   │   │   │   └── SchemaUtil.java
│   │   │   ├── sqlengine
│   │   │   │   ├── AllJobFinishedListener.java
│   │   │   │   ├── BatchSQLJob.java
│   │   │   │   ├── EngineCtx.java
│   │   │   │   ├── mpp
│   │   │   │   │   ├── AbstractDataNodeMerge.java
│   │   │   │   │   ├── ColMeta.java
│   │   │   │   │   ├── ColumnRoutePair.java
│   │   │   │   │   ├── DataMergeService.java
│   │   │   │   │   ├── DataNodeMergeManager.java
│   │   │   │   │   ├── HavingCols.java
│   │   │   │   │   ├── LoadData.java
│   │   │   │   │   ├── MergeCol.java
│   │   │   │   │   ├── model
│   │   │   │   │   │   ├── NodeRowDataPacket.java
│   │   │   │   │   │   └── RangRowDataPacket.java
│   │   │   │   │   ├── OrderCol.java
│   │   │   │   │   ├── PackWraper.java
│   │   │   │   │   ├── RangeValue.java
│   │   │   │   │   ├── RangRowDataPacketSorter.java
│   │   │   │   │   ├── RowDataPacketGrouper.java
│   │   │   │   │   ├── RowDataPacketSorter.java
│   │   │   │   │   ├── tmp
│   │   │   │   │   │   ├── HeapItf.java
│   │   │   │   │   │   ├── IntMinHeap.java
│   │   │   │   │   │   ├── MaxHeap.java
│   │   │   │   │   │   ├── MinHeap.java
│   │   │   │   │   │   ├── RowDataCmp.java
│   │   │   │   │   │   └── RowDataSorter.java
│   │   │   │   │   └── UnsafeRowGrouper.java
│   │   │   │   ├── MultiRowSQLQueryResultHandler.java
│   │   │   │   ├── OneRawSQLQueryResultHandler.java
│   │   │   │   ├── SQLJobHandler.java
│   │   │   │   ├── SQLJob.java
│   │   │   │   ├── SQLQueryResult.java
│   │   │   │   └── SQLQueryResultListener.java
│   │   │   ├── statistic
│   │   │   │   ├── CommandCount.java
│   │   │   │   ├── DataSourceSyncRecorder.java
│   │   │   │   ├── HeartbeatRecorder.java
│   │   │   │   ├── SQLRecorder.java
│   │   │   │   ├── SQLRecord.java
│   │   │   │   └── stat
│   │   │   │   ├── Histogram.java
│   │   │   │   ├── HostStatAnalyzer.java
│   │   │   │   ├── QueryConditionAnalyzer.java
│   │   │   │   ├── QueryResultDispatcher.java
│   │   │   │   ├── QueryResult.java
│   │   │   │   ├── QueryResultListener.java
│   │   │   │   ├── SqlFrequency.java
│   │   │   │   ├── SqlResultSet.java
│   │   │   │   ├── SqlResultSizeRecorder.java
│   │   │   │   ├── TableStatAnalyzer.java
│   │   │   │   ├── TableStat.java
│   │   │   │   ├── UserSqlHighStat.java
│   │   │   │   ├── UserSqlLargeStat.java
│   │   │   │   ├── UserSqlLastStat.java
│   │   │   │   ├── UserSqlRWStat.java
│   │   │   │   ├── UserStatAnalyzer.java
│   │   │   │   └── UserStat.java
│   │   │   └── util
│   │   │   ├── ByteBufferUtil.java
│   │   │   ├── ByteUtil.java
│   │   │   ├── CircularArrayList.java
│   │   │   ├── cmd
│   │   │   │   └── CmdArgs.java
│   │   │   ├── CollectionUtil.java
│   │   │   ├── CompareUtil.java
│   │   │   ├── CompressUtil.java
│   │   │   ├── dataMigrator
│   │   │   │   ├── ConfigComparer.java
│   │   │   │   ├── DataClearRunner.java
│   │   │   │   ├── DataIOFactory.java
│   │   │   │   ├── dataIOImpl
│   │   │   │   │   └── MysqlDataIO.java
│   │   │   │   ├── DataIO.java
│   │   │   │   ├── DataMigrateRunner.java
│   │   │   │   ├── DataMigratorArgs.java
│   │   │   │   ├── DataMigrator.java
│   │   │   │   ├── DataMigratorUtil.java
│   │   │   │   ├── DataNodeClearGroup.java
│   │   │   │   ├── DataNode.java
│   │   │   │   ├── DataNodeMigrateInfo.java
│   │   │   │   ├── MigratorConditonFilesMaker.java
│   │   │   │   └── TableMigrateInfo.java
│   │   │   ├── DateUtil.java
│   │   │   ├── DecryptUtil.java
│   │   │   ├── exception
│   │   │   │   ├── DataMigratorException.java
│   │   │   │   ├── ErrorPacketException.java
│   │   │   │   ├── HeartbeatException.java
│   │   │   │   ├── MurmurHashException.java
│   │   │   │   ├── RehashException.java
│   │   │   │   ├── UnknownCharsetException.java
│   │   │   │   ├── UnknownDataNodeException.java
│   │   │   │   ├── UnknownPacketException.java
│   │   │   │   └── UnknownTxIsolationException.java
│   │   │   ├── ExecutorUtil.java
│   │   │   ├── FastByteOperations.java
│   │   │   ├── FormatUtil.java
│   │   │   ├── HexFormatUtil.java
│   │   │   ├── IntegerUtil.java
│   │   │   ├── LongUtil.java
│   │   │   ├── MysqlDefs.java
│   │   │   ├── NameableExecutor.java
│   │   │   ├── NameableThreadFactory.java
│   │   │   ├── ObjectUtil.java
│   │   │   ├── ProcessUtil.java
│   │   │   ├── RandomUtil.java
│   │   │   ├── rehasher
│   │   │   │   ├── HashType.java
│   │   │   │   ├── RehashCmdArgs.java
│   │   │   │   └── RehashLauncher.java
│   │   │   ├── ResultSetUtil.java
│   │   │   ├── SelectorUtil.java
│   │   │   ├── SetIgnoreUtil.java
│   │   │   ├── SmallSet.java
│   │   │   ├── SplitUtil.java
│   │   │   ├── StreamGobble.java
│   │   │   ├── StringUtil.java
│   │   │   ├── TimeUtil.java
│   │   │   └── ZKUtils.java
│   │   └── resources
│   │   ├── autopartition-long.txt
│   │   ├── auto-sharding-long.txt
│   │   ├── auto-sharding-rang-mod.txt
│   │   ├── cacheservice.properties
│   │   ├── dbseq.sql
│   │   ├── ehcache.xml
│   │   ├── index_to_charset.properties
│   │   ├── log4j2.xml
│   │   ├── migrateTables.properties
│   │   ├── myid.properties
│   │   ├── partition-hash-int.txt
│   │   ├── partition-range-mod.txt
│   │   ├── rule.dtd
│   │   ├── rule.xml
│   │   ├── schema.dtd
│   │   ├── schema.xml
│   │   ├── sequence_conf.properties
│   │   ├── sequence_db_conf.properties
│   │   ├── sequence_distributed_conf.properties
│   │   ├── sequence_time_conf.properties
│   │   ├── server.dtd
│   │   ├── server.xml
│   │   ├── sharding-by-enum.txt
│   │   ├── zkconf
│   │   │   ├── autopartition-long.txt
│   │   │   ├── auto-sharding-long.txt
│   │   │   ├── auto-sharding-rang-mod.txt
│   │   │   ├── cacheservice.properties
│   │   │   ├── ehcache.xml
│   │   │   ├── index_to_charset.properties
│   │   │   ├── partition-hash-int.txt
│   │   │   ├── partition-range-mod.txt
│   │   │   ├── rule.xml
│   │   │   ├── schema.xml
│   │   │   ├── sequence_conf.properties
│   │   │   ├── sequence_db_conf.properties
│   │   │   ├── sequence_distributed_conf-mycat_fz_01.properties
│   │   │   ├── sequence_distributed_conf.properties
│   │   │   ├── sequence_time_conf-mycat_fz_01.properties
│   │   │   ├── sequence_time_conf.properties
│   │   │   ├── server-mycat_fz_01.xml
│   │   │   ├── server.xml
│   │   │   └── sharding-by-enum.txt
│   │   └── zkdownload
│   │   └── auto-sharding-long.txt
│   └── test
│   ├── java
│   │   ├── demo
│   │   │   ├── catlets
│   │   │   │   └── MyHellowJoin.java
│   │   │   └── test
│   │   │   ├── ByteArrayToHexArray.java
│   │   │   └── TestClass1.java
│   │   └── io
│   │   └── mycat
│   │   ├── backend
│   │   │   └── jdbc
│   │   │   └── mongodb
│   │   │   ├── MongoClientPropertyHelperTest.java
│   │   │   └── MongoEmbeddedObjectProcessorTest.java
│   │   ├── buffer
│   │   │   ├── TestByteBufferArena.java
│   │   │   ├── TestDirectByteBufferPool.java
│   │   │   └── TestMycatMemoryAlloctor.java
│   │   ├── BufferPerformanceMain.java
│   │   ├── cache
│   │   │   ├── DefaultLayedCachePoolTest.java
│   │   │   ├── EnCachePoolTest.java
│   │   │   └── TestCachePoolPerformance.java
│   │   ├── classload
│   │   │   └── TestDynClassLoad.java
│   │   ├── config
│   │   │   └── ConfigTest.java
│   │   ├── ConfigInitializerTest.java
│   │   ├── EchoBioServer.java
│   │   ├── ExecutorTestMain.java
│   │   ├── heartbeat
│   │   │   ├── HeartbeatConfigForTest.java
│   │   │   ├── HeartbeatContext.java
│   │   │   └── HeartbeatStartup.java
│   │   ├── memory
│   │   │   └── unsafe
│   │   │   ├── array
│   │   │   │   └── LongArraySuite.java
│   │   │   ├── hash
│   │   │   │   └── Murmur3_x86_32Suite.java
│   │   │   ├── map
│   │   │   │   ├── AbstractBytesToBytesMapSuite.java
│   │   │   │   ├── BytesToBytesMapOffHeapSuite.java
│   │   │   │   ├── BytesToBytesMapOnHeapSuite.java
│   │   │   │   ├── MapSorterByValueTest.java
│   │   │   │   └── UnsafeFixedWidthAggregationMapSuite.java
│   │   │   ├── memory
│   │   │   │   ├── MemoryManagerSuite.java
│   │   │   │   ├── MycatMemoryTest.java
│   │   │   │   ├── TaskMemoryManagerSuite.java
│   │   │   │   ├── TestMemoryConsumer.java
│   │   │   │   └── TestMemoryManager.java
│   │   │   ├── PlatformUtilSuite.java
│   │   │   ├── row
│   │   │   │   ├── UnsafeRowList.java
│   │   │   │   └── UnsafeRowSuite.java
│   │   │   ├── sort
│   │   │   │   ├── HashPartitioner.java
│   │   │   │   ├── TestTimSort.java
│   │   │   │   ├── UnsafeExternalRowSorterTest.java
│   │   │   │   ├── UnsafeExternalSorterRadixSortSuite.java
│   │   │   │   ├── UnsafeExternalSorterSuite.java
│   │   │   │   ├── UnsafeInMemorySorterRadixSortSuite.java
│   │   │   │   └── UnsafeInMemorySorterSuite.java
│   │   │   ├── storage
│   │   │   │   ├── BlockManagerTest.java
│   │   │   │   └── SerializerManagerTest.java
│   │   │   └── types
│   │   │   ├── CalendarIntervalSuite.java
│   │   │   └── UTF8StringSuite.java
│   │   ├── migrate
│   │   │   └── MigrateUtilsTest.java
│   │   ├── model
│   │   │   ├── M1.java
│   │   │   ├── M1Main.java
│   │   │   ├── M2.java
│   │   │   ├── M2Main.java
│   │   │   └── TransferObject.java
│   │   ├── mpp
│   │   │   └── TestSorter.java
│   │   ├── mysql
│   │   │   ├── MySQLMessageTest.java
│   │   │   └── ResultSetPacketParse.java
│   │   ├── parser
│   │   │   ├── druid
│   │   │   │   ├── DruidSelectParserTest.java
│   │   │   │   ├── DruidSequenceHandlerTest.java
│   │   │   │   ├── DruidUpdateParserTest.java
│   │   │   │   └── MycatSchemaStatVisitorTest.java
│   │   │   ├── ManagerParserTest.java
│   │   │   ├── ManagerParserTestPerf.java
│   │   │   ├── Performance.java
│   │   │   ├── primitive
│   │   │   │   └── TestFunctionParser.java
│   │   │   ├── ServerParserTest.java
│   │   │   ├── ServerParserTestPerf.java
│   │   │   ├── ServerParseTest.java
│   │   │   ├── TestEscapeProcess.java
│   │   │   └── util
│   │   │   └── PairUtilTest.java
│   │   ├── performance
│   │   │   ├── AbstractMultiTreadBatchTester.java
│   │   │   ├── GoodsInsertJob.java
│   │   │   ├── RandomDataValueUtil.java
│   │   │   ├── SimpleConPool.java
│   │   │   ├── TestGlobalTableInsertPerf.java
│   │   │   ├── TestInsertGlobalSeqPerf.java
│   │   │   ├── TestInsertPerf.java
│   │   │   ├── TestMaxConnection.java
│   │   │   ├── TestMergeSelectPerf.java
│   │   │   ├── TestMergeSorter.java
│   │   │   ├── TestRandomDataUtil.java
│   │   │   ├── TestSelectPerf.java
│   │   │   ├── TestUpdatePerf.java
│   │   │   ├── TravelRecordGlobalSeqInsertJob.java
│   │   │   ├── TravelRecordInsertJob.java
│   │   │   ├── TravelRecordMergeJob.java
│   │   │   ├── TravelRecordSelectJob.java
│   │   │   ├── TravelRecordUpdateJob.java
│   │   │   ├── UserTableInsertJob.java
│   │   │   └── UserTableSelectJob.java
│   │   ├── postgres
│   │   │   └── PostgresTest.java
│   │   ├── queue
│   │   │   ├── FixedQueue.java
│   │   │   ├── Queue.java
│   │   │   ├── QueuePerfMain.java
│   │   │   └── QueueSimpleMain.java
│   │   ├── route
│   │   │   ├── DDLRouteTest.java
│   │   │   ├── DeleteSqlParseTest.java
│   │   │   ├── DQLRouteTest.java
│   │   │   ├── DruidDb2SqlParserTest.java
│   │   │   ├── DruidMysqlCreateTableTest.java
│   │   │   ├── DruidMysqlHavingTest.java
│   │   │   ├── DruidMysqlRouteStrategyTest.java
│   │   │   ├── DruidMysqlSqlParserTest.java
│   │   │   ├── DruidMysqlSqlSubqueriesParserTest.java
│   │   │   ├── DruidOracleSqlParserTest.java
│   │   │   ├── DruidPostgresqlSqlParserTest.java
│   │   │   ├── DruidSqlServerSqlParserTest.java
│   │   │   ├── function
│   │   │   │   ├── AutoPartitionByLongTest.java
│   │   │   │   ├── PartitionByCRC32PreSlotTest.java
│   │   │   │   ├── PartitionByDateTest.java
│   │   │   │   ├── PartitionByHashModTest.java
│   │   │   │   ├── PartitionByHotDateTest.java
│   │   │   │   ├── PartitionByJumpConsistentHashTest.java
│   │   │   │   ├── PartitionByMonthTest.java
│   │   │   │   ├── PartitionByPatternTest.java
│   │   │   │   ├── PartitionByPrefixPatternTest.java
│   │   │   │   ├── PartitionByRangeDateHashTest.java
│   │   │   │   ├── PartitionByRangeModTest.java
│   │   │   │   ├── PartitionByStringTest.java
│   │   │   │   ├── RuleFunctionSuitTableTest.java
│   │   │   │   ├── TestLatestMonthPartion.java
│   │   │   │   └── TestNumberParseUtil.java
│   │   │   ├── HintDBTypeTest.java
│   │   │   ├── HintTest.java
│   │   │   ├── parser
│   │   │   │   └── druid
│   │   │   │   └── impl
│   │   │   │   └── DefaultDruidParserTest.java
│   │   │   ├── perf
│   │   │   │   ├── NoShardingSpace.java
│   │   │   │   ├── ShardingDefaultSpace.java
│   │   │   │   └── ShardingMultiTableSpace.java
│   │   │   ├── TestSelectBetweenSqlParser.java
│   │   │   └── util
│   │   │   ├── PartitionForSingle.java
│   │   │   ├── PartitionUtilTest.java
│   │   │   └── RouterUtilTest.java
│   │   ├── sequence
│   │   │   ├── DistributedSequenceHandlerTest.java
│   │   │   ├── IncrSequenceZKHandlerTest.java
│   │   │   ├── SequenceHandlerTest.java
│   │   │   └── SequenceTest.java
│   │   ├── server
│   │   │   ├── handler
│   │   │   │   └── ServerHandlerTest.java
│   │   │   └── interceptor
│   │   │   └── impl
│   │   │   └── GlobalTableUtilTest.java
│   │   ├── SimpleCachePool.java
│   │   ├── sqlexecute
│   │   │   ├── BaseSQLExeTest.java
│   │   │   ├── MultiThreadSelectTest.java
│   │   │   ├── MultiThreadSequnceTest.java
│   │   │   ├── MycatMulitJdbcVersionTest.java
│   │   │   ├── RollbackTest.java
│   │   │   ├── ServerPrepareTest.java
│   │   │   ├── StandBatchInsertTest.java
│   │   │   ├── TestJdbc.java
│   │   │   └── TestPrepareSql.java
│   │   ├── statistic
│   │   │   ├── SQLStatisticsMain.java
│   │   │   └── TestConcurrentSafety.java
│   │   ├── util
│   │   │   ├── ArrayPerformanceMain.java
│   │   │   ├── BitTest.java
│   │   │   ├── ConcurrentHashMapMain.java
│   │   │   ├── HashMapMain.java
│   │   │   ├── HexFormatUtilMain.java
│   │   │   ├── HexFormatUtilTest.java
│   │   │   ├── LockPerfMain.java
│   │   │   ├── MapPerfMain.java
│   │   │   ├── SmallSetTest.java
│   │   │   ├── SplitUtilTest.java
│   │   │   ├── StringHashPerfMain.java
│   │   │   ├── StringUtilTest.java
│   │   │   └── SyncPerfMain.java
│   │   └── VolatileTest.java
│   └── resources
│   ├── autopartition-long2.txt
│   ├── autopartition-long-dupl.txt
│   ├── autopartition-long.txt
│   ├── blob
│   │   ├── image0.jpg
│   │   ├── image1.png
│   │   ├── image2.png
│   │   └── image3.png
│   ├── config
│   │   ├── rule.xml
│   │   └── schema.xml
│   ├── ehcache.xml
│   ├── log4j2.xml
│   ├── partition-pattern.txt
│   ├── partition_prefix_pattern.txt
│   ├── partition-range-mod.txt
│   ├── route
│   │   ├── rule.xml
│   │   └── schema.xml
│   ├── rule.xml
│   ├── schema.xml
│   ├── sequence_conf.properties
│   ├── server.xml
│   ├── sharding.txt
│   └── zk-create-test.yaml
├── test-output
│   ├── bullet_point.png
│   ├── collapseall.gif
│   ├── Default suite
│   │   ├── Default test.html
│   │   └── Default test.xml
│   ├── emailable-report.html
│   ├── failed.png
│   ├── index.html
│   ├── jquery-1.7.1.min.js
│   ├── navigator-bullet.png
│   ├── old
│   │   ├── Default suite
│   │   │   ├── classes.html
│   │   │   ├── Default test.properties
│   │   │   ├── groups.html
│   │   │   ├── index.html
│   │   │   ├── main.html
│   │   │   ├── methods-alphabetical.html
│   │   │   ├── methods.html
│   │   │   ├── methods-not-run.html
│   │   │   ├── reporter-output.html
│   │   │   ├── testng.xml.html
│   │   │   └── toc.html
│   │   └── index.html
│   ├── passed.png
│   ├── skipped.png
│   ├── testng.css
│   ├── testng-reports.css
│   ├── testng-reports.js
│   └── testng-results.xml
├── tmlogs
│   └── tmlog-1.log
├── version.txt
└── version.txt.template

212 directories, 1179 files