更改java package(包名大小写问题)

README.md

@@ -952,7 +952,7 @@ xa
 当数据源提供者为
 
 ```yaml
-datasourceProviderClass: io.mycat.datasource.jdbc.datasourceProvider.AtomikosDatasourceProvider
+datasourceProviderClass: io.mycat.datasource.jdbc.datasourceprovider.AtomikosDatasourceProvider
 ```
 
 
@@ -968,7 +968,7 @@ datasourceProviderClass: io.mycat.datasource.jdbc.datasourceProvider.AtomikosDat
 例如
 
 ```yaml
-datasourceProviderClass: io.mycat.datasource.jdbc.datasourceProvider.DruidDatasourceProvider
+datasourceProviderClass: io.mycat.datasource.jdbc.datasourceprovider.DruidDatasourceProvider
 ```
 
 当使用此数据源提供者的时候使用workerPool线程池,当设置xa事务的时候,是使用此DruidDatasourceProvider实现的事务是本地事务,多个连接commit在阶段失败,已经commit的连接不能回滚
@@ -1032,7 +1032,7 @@ datasource:
    initSqlsGetConnection: false
   }
   ]
-  datasourceProviderClass: io.mycat.datasource.jdbc.datasourceProvider.AtomikosDatasourceProvider
+  datasourceProviderClass: io.mycat.datasource.jdbc.datasourceprovider.AtomikosDatasourceProvider
   timer: {initialDelay: 1000, period: 5, timeUnit: SECONDS}
 ```
 

common/src/main/java/io/mycat/SessionOpt.java

@@ -1,7 +1,7 @@
 package io.mycat;
 
 import io.mycat.beans.mycat.TransactionType;
-import io.mycat.bindThread.BindThreadKey;
+import io.mycat.bindthread.BindThreadKey;
 /**
  * @author Junwen Chen
  **/

common/src/main/java/io/mycat/api/collector/BinaryResultSetTransforCollector.java

@@ -17,8 +17,6 @@
 
 import io.mycat.beans.mysql.packet.ColumnDefPacket;
 import io.mycat.beans.mysql.packet.MySQLPacket;
-import io.mycat.logTip.MycatLogger;
-import io.mycat.logTip.MycatLoggerFactory;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

common/src/main/java/io/mycat/api/collector/OneResultSetCollector.java

@@ -17,9 +17,6 @@
 package io.mycat.api.collector;
 
 import io.mycat.beans.mysql.packet.ColumnDefPacket;
-import io.mycat.logTip.MycatLogger;
-import io.mycat.logTip.MycatLoggerFactory;
-import io.mycat.util.StringUtil;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

common/src/main/java/io/mycat/beans/mycat/JdbcRowBaseIterator.java

@@ -15,10 +15,7 @@
 package io.mycat.beans.mycat;
 
 import io.mycat.MycatException;
-import io.mycat.api.collector.OneResultSetCollector;
 import io.mycat.api.collector.RowBaseIterator;
-import io.mycat.logTip.MycatLogger;
-import io.mycat.logTip.MycatLoggerFactory;
 import lombok.SneakyThrows;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

common/src/main/java/io/mycat/beans/mysql/packet/ProxyBuffer.java

@@ -14,10 +14,7 @@
  */
 package io.mycat.beans.mysql.packet;
 
-import io.mycat.beans.mycat.JdbcRowBaseIterator;
 import io.mycat.buffer.BufferPool;
-import io.mycat.logTip.MycatLogger;
-import io.mycat.logTip.MycatLoggerFactory;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

common/src/main/java/io/mycat/bindThread/BindThread.java → common/src/main/java/io/mycat/bindthread/BindThread.java

@@ -13,7 +13,7 @@
  * not, see <http://www.gnu.org/licenses/>.
  */
 
-package io.mycat.bindThread;
+package io.mycat.bindthread;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

common/src/main/java/io/mycat/bindThread/BindThreadCallback.java → common/src/main/java/io/mycat/bindthread/BindThreadCallback.java

@@ -13,7 +13,7 @@
  * not, see <http://www.gnu.org/licenses/>.
  */
 
-package io.mycat.bindThread;
+package io.mycat.bindthread;
 
 public interface BindThreadCallback<KEY extends BindThreadKey, PROCESS extends BindThread> {
 

common/src/main/java/io/mycat/bindThread/BindThreadKey.java → common/src/main/java/io/mycat/bindthread/BindThreadKey.java

@@ -13,7 +13,7 @@
  * not, see <http://www.gnu.org/licenses/>.
  */
 
-package io.mycat.bindThread;
+package io.mycat.bindthread;
 
 public interface BindThreadKey {
 

common/src/main/java/io/mycat/bindThread/BindThreadPool.java → common/src/main/java/io/mycat/bindthread/BindThreadPool.java

@@ -12,7 +12,7 @@
  * You should have received a copy of the GNU General Public License along with this program.  If
  * not, see <http://www.gnu.org/licenses/>.
  */
-package io.mycat.bindThread;
+package io.mycat.bindthread;
 
 import io.mycat.MycatException;
 import io.mycat.MycatWorkerProcessor;

common/src/main/java/io/mycat/logTip/MycatLogger.java → common/src/main/java/io/mycat/logtip/MycatLogger.java

@@ -13,7 +13,7 @@
  * not, see <http://www.gnu.org/licenses/>.
  */
 
-package io.mycat.logTip;
+package io.mycat.logtip;
 
 import io.mycat.beans.mysql.packet.ErrorPacketImpl;
 import org.slf4j.Logger;

common/src/main/java/io/mycat/logTip/MycatLoggerFactory.java → common/src/main/java/io/mycat/logtip/MycatLoggerFactory.java

@@ -13,7 +13,7 @@
  * not, see <http://www.gnu.org/licenses/>.
  */
 
-package io.mycat.logTip;
+package io.mycat.logtip;
 
 public class MycatLoggerFactory {
 

common/src/main/java/io/mycat/logTip/ScanDoc.java → common/src/main/java/io/mycat/logtip/ScanDoc.java

@@ -13,7 +13,7 @@
  * not, see <http://www.gnu.org/licenses/>.
  */
 
-package io.mycat.logTip;
+package io.mycat.logtip;
 
 import java.io.IOException;
 import java.nio.file.Files;

common/src/main/java/io/mycat/sequenceModifier/ModifyCallback.java → common/src/main/java/io/mycat/sequencemodifier/ModifyCallback.java

@@ -12,7 +12,7 @@
  * You should have received a copy of the GNU General Public License along with this program.  If
  * not, see <http://www.gnu.org/licenses/>.
  */
-package io.mycat.sequenceModifier;
+package io.mycat.sequencemodifier;
 
 public interface ModifyCallback {
 

common/src/main/java/io/mycat/sequenceModifier/SequenceModifier.java → common/src/main/java/io/mycat/sequencemodifier/SequenceModifier.java

@@ -12,7 +12,7 @@
  * You should have received a copy of the GNU General Public License along with this program.  If
  * not, see <http://www.gnu.org/licenses/>.
  */
-package io.mycat.sequenceModifier;
+package io.mycat.sequencemodifier;
 
 import java.util.Map;
 

common/src/main/java/io/mycat/util/CachingSha2PasswordPlugin.java

@@ -31,9 +31,6 @@
 
 import io.mycat.MycatException;
 import io.mycat.beans.mysql.ServerVersion;
-import io.mycat.beans.mysql.packet.ProxyBuffer;
-import io.mycat.logTip.MycatLogger;
-import io.mycat.logTip.MycatLoggerFactory;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

common/src/main/java/io/mycat/util/CharsetUtil.java

@@ -23,9 +23,6 @@
  */
 package io.mycat.util;
 
-import io.mycat.beans.mysql.packet.ProxyBuffer;
-import io.mycat.logTip.MycatLogger;
-import io.mycat.logTip.MycatLoggerFactory;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

common/src/main/java/io/mycat/util/DumpUtil.java

@@ -16,8 +16,6 @@
  */
 package io.mycat.util;
 
-import io.mycat.logTip.MycatLogger;
-import io.mycat.logTip.MycatLoggerFactory;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

common/src/main/java/io/mycat/util/DynaClassLoader.java

@@ -1,7 +1,5 @@
 package io.mycat.util;
 
-import io.mycat.logTip.MycatLogger;
-import io.mycat.logTip.MycatLoggerFactory;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

common/src/main/java/io/mycat/util/JavaUtils.java

@@ -19,8 +19,6 @@
 
 import com.google.common.base.Preconditions;
 import com.google.common.collect.ImmutableMap;
-import io.mycat.logTip.MycatLogger;
-import io.mycat.logTip.MycatLoggerFactory;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

common/src/main/java/io/mycat/util/MysqlNativePasswordPluginUtil.java

@@ -17,8 +17,6 @@
 package io.mycat.util;
 
 
-import io.mycat.logTip.MycatLogger;
-import io.mycat.logTip.MycatLoggerFactory;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

common/src/main/java/io/mycat/util/StringUtil.java

@@ -23,8 +23,6 @@
  */
 package io.mycat.util;
 
-import io.mycat.logTip.MycatLogger;
-import io.mycat.logTip.MycatLoggerFactory;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

common/src/main/java/io/mycat/util/nio/SelectorUtil.java

@@ -1,8 +1,5 @@
 package io.mycat.util.nio;
 
-import io.mycat.logTip.MycatLogger;
-import io.mycat.logTip.MycatLoggerFactory;
-import io.mycat.util.StringUtil;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

datasource/src/main/java/io/mycat/datasource/jdbc/JdbcRuntime.java

@@ -25,7 +25,7 @@
 import io.mycat.datasource.jdbc.datasource.DefaultConnection;
 import io.mycat.datasource.jdbc.datasource.JdbcConnectionManager;
 import io.mycat.datasource.jdbc.datasource.JdbcDataSource;
-import io.mycat.datasource.jdbc.datasourceProvider.AtomikosDatasourceProvider;
+import io.mycat.datasource.jdbc.datasourceprovider.AtomikosDatasourceProvider;
 import io.mycat.plug.PlugRuntime;
 import io.mycat.replica.ReplicaSelectorRuntime;
 import io.mycat.replica.heartbeat.HeartBeatStrategy;

datasource/src/main/java/io/mycat/datasource/jdbc/datasourceProvider/AtomikosDatasourceProvider.java → datasource/src/main/java/io/mycat/datasource/jdbc/datasourceprovider/AtomikosDatasourceProvider.java

@@ -12,7 +12,7 @@
  * You should have received a copy of the GNU General Public License along with this program.  If
  * not, see <http://www.gnu.org/licenses/>.
  */
-package io.mycat.datasource.jdbc.datasourceProvider;
+package io.mycat.datasource.jdbc.datasourceprovider;
 
 import com.atomikos.icatch.jta.UserTransactionImp;
 import com.atomikos.jdbc.AtomikosDataSourceBean;

datasource/src/main/java/io/mycat/datasource/jdbc/datasourceProvider/DruidDatasourceProvider.java → datasource/src/main/java/io/mycat/datasource/jdbc/datasourceprovider/DruidDatasourceProvider.java

@@ -12,7 +12,7 @@
  * You should have received a copy of the GNU General Public License along with this program.  If
  * not, see <http://www.gnu.org/licenses/>.
  */
-package io.mycat.datasource.jdbc.datasourceProvider;
+package io.mycat.datasource.jdbc.datasourceprovider;
 
 import com.alibaba.druid.pool.DruidDataSource;
 import io.mycat.config.DatasourceRootConfig;

datasource/src/main/java/io/mycat/datasource/jdbc/transactionSession/JTATransactionSession.java → datasource/src/main/java/io/mycat/datasource/jdbc/transactionsession/JTATransactionSession.java

@@ -12,7 +12,7 @@
  * You should have received a copy of the GNU General Public License along with this program.  If
  * not, see <http://www.gnu.org/licenses/>.
  */
-package io.mycat.datasource.jdbc.transactionSession;
+package io.mycat.datasource.jdbc.transactionsession;
 
 import io.mycat.MycatDataContext;
 import io.mycat.ThreadUsageEnum;

datasource/src/main/java/io/mycat/datasource/jdbc/transactionSession/TransactionSessionTemplate.java → datasource/src/main/java/io/mycat/datasource/jdbc/transactionsession/TransactionSessionTemplate.java

@@ -1,4 +1,4 @@
-package io.mycat.datasource.jdbc.transactionSession;
+package io.mycat.datasource.jdbc.transactionsession;
 
 import io.mycat.DataSourceNearness;
 import io.mycat.MycatConnection;

doc/22-mycat-jdbc.md

@@ -7,7 +7,7 @@ author:junwen 2019-7-22
 ## jdbcDriver.yml配置
 
 ```yaml
-datasourceProviderClass: io.mycat.datasource.jdbc.datasourceProvider.AtomikosDatasourceProvider
+datasourceProviderClass: io.mycat.datasource.jdbc.datasourceprovider.AtomikosDatasourceProvider
 maxPengdingLimit: -1
 waitTaskTimeout: 5
 timeUnit: SECONDS
@@ -53,11 +53,11 @@ datasourceProviderClass更改即可变更事务实现
 
 Atomikos XA事务,其中这个事务实现可能会针对一些场景使用优化尽量使用本地事务
 
-io.mycat.datasource.jdbc.datasourceProvider.AtomikosDatasourceProvider
+io.mycat.datasource.jdbc.datasourceprovider.AtomikosDatasourceProvider
 
 本地事务
 
-io.mycat.datasource.jdbc.datasourceProvider.DruidDatasourceProvider
+io.mycat.datasource.jdbc.datasourceprovider.DruidDatasourceProvider
 
 
 

example/src/test/java/io/mycat/example/customRule/CustomRuleExample.java → example/src/test/java/io/mycat/example/customrule/CustomRuleExample.java

@@ -1,4 +1,4 @@
-package io.mycat.example.customRule;
+package io.mycat.example.customrule;
 
 import io.mycat.ConfigProvider;
 import io.mycat.MycatCore;

example/src/test/java/io/mycat/example/customRuleSegmentQuery/CustomRuleExample.java → example/src/test/java/io/mycat/example/customrulesegmentquery/CustomRuleExample.java

@@ -1,4 +1,4 @@
-package io.mycat.example.customRuleSegmentQuery;
+package io.mycat.example.customrulesegmentquery;
 
 import io.mycat.ConfigProvider;
 import io.mycat.MycatCore;

example/src/test/java/io/mycat/example/readWriteSeparation/ReadWriteSeparationExample.java → example/src/test/java/io/mycat/example/readwriteseparation/ReadWriteSeparationExample.java

@@ -1,4 +1,4 @@
-package io.mycat.example.readWriteSeparation;
+package io.mycat.example.readwriteseparation;
 
 import io.mycat.ConfigProvider;
 import io.mycat.MycatCore;

example/src/test/java/io/mycat/example/shardingLocal/ShardingLocalExample.java → example/src/test/java/io/mycat/example/shardinglocal/ShardingLocalExample.java

@@ -1,4 +1,4 @@
-package io.mycat.example.shardingLocal;
+package io.mycat.example.shardinglocal;
 
 import io.mycat.ConfigProvider;
 import io.mycat.MycatCore;

example/src/test/java/io/mycat/example/shardingLocalFail/ShardingLocalFailExample.java → example/src/test/java/io/mycat/example/shardinglocalfail/ShardingLocalFailExample.java

@@ -1,4 +1,4 @@
-package io.mycat.example.shardingLocalFail;
+package io.mycat.example.shardinglocalfail;
 
 import io.mycat.ConfigProvider;
 import io.mycat.MycatCore;
@@ -11,10 +11,7 @@
 
 import java.nio.file.Paths;
 import java.sql.Connection;
-import java.sql.ResultSet;
 import java.sql.Statement;
-import java.util.HashSet;
-import java.util.Set;
 import java.util.concurrent.TimeUnit;
 
 public class ShardingLocalFailExample {

example/src/test/java/io/mycat/example/shardingRw/ShardingRwExample.java → example/src/test/java/io/mycat/example/shardingrw/ShardingRwExample.java

@@ -1,4 +1,4 @@
-package io.mycat.example.shardingRw;
+package io.mycat.example.shardingrw;
 
 import io.mycat.ConfigProvider;
 import io.mycat.MycatCore;

example/src/test/java/io/mycat/example/shardingXA/ShardingXAExample.java → example/src/test/java/io/mycat/example/shardingxa/ShardingXAExample.java

@@ -1,4 +1,4 @@
-package io.mycat.example.shardingXA;
+package io.mycat.example.shardingxa;
 
 import io.mycat.ConfigProvider;
 import io.mycat.MycatCore;

example/src/test/java/io/mycat/example/shardingXAFail/ShardingXAFailExample.java → example/src/test/java/io/mycat/example/shardingxafail/ShardingXAFailExample.java

@@ -1,4 +1,4 @@
-package io.mycat.example.shardingXAFail;
+package io.mycat.example.shardingxafail;
 
 import io.mycat.ConfigProvider;
 import io.mycat.MycatCore;

example/src/test/resources/io/mycat/example/booster/mycat.yml

@@ -49,7 +49,7 @@ datasource:
                   initSqlsGetConnection: true
                 }
   ]
-  datasourceProviderClass: io.mycat.datasource.jdbc.datasourceProvider.AtomikosDatasourceProvider
+  datasourceProviderClass: io.mycat.datasource.jdbc.datasourceprovider.AtomikosDatasourceProvider
   timer: {initialDelay: 10, period: 5, timeUnit: SECONDS}
 cluster: #集群,数据源选择器,既可以mycat自行检查数据源可用也可以通过mycat提供的外部接口设置设置数据源可用信息影响如何使用数据源
   close: true  #关闭集群心跳,此时集群认为所有数据源都是可用的,可以通过mycat提供的外部接口设置数据源可用信息达到相同效果

example/src/test/resources/io/mycat/example/customRule/mycat.yml → example/src/test/resources/io/mycat/example/customrule/mycat.yml

@@ -43,7 +43,7 @@ datasource:
                     initSqlsGetConnection: true
                 }
   ]
-  datasourceProviderClass: io.mycat.datasource.jdbc.datasourceProvider.AtomikosDatasourceProvider
+  datasourceProviderClass: io.mycat.datasource.jdbc.datasourceprovider.AtomikosDatasourceProvider
   timer: {initialDelay: 10, period: 5, timeUnit: SECONDS}
 cluster: #集群,数据源选择器,既可以mycat自行检查数据源可用也可以通过mycat提供的外部接口设置设置数据源可用信息影响如何使用数据源
   close: true  #关闭集群心跳,此时集群认为所有数据源都是可用的,可以通过mycat提供的外部接口设置数据源可用信息达到相同效果

example/src/test/resources/io/mycat/example/customRuleSegmentQuery/mycat.yml → example/src/test/resources/io/mycat/example/customrulesegmentquery/mycat.yml

@@ -43,7 +43,7 @@ datasource:
                     initSqlsGetConnection: true
                 }
   ]
-  datasourceProviderClass: io.mycat.datasource.jdbc.datasourceProvider.AtomikosDatasourceProvider
+  datasourceProviderClass: io.mycat.datasource.jdbc.datasourceprovider.AtomikosDatasourceProvider
   timer: {initialDelay: 10, period: 5, timeUnit: SECONDS}
 cluster: #集群,数据源选择器,既可以mycat自行检查数据源可用也可以通过mycat提供的外部接口设置设置数据源可用信息影响如何使用数据源
   close: true  #关闭集群心跳,此时集群认为所有数据源都是可用的,可以通过mycat提供的外部接口设置数据源可用信息达到相同效果

example/src/test/resources/io/mycat/example/manager/mycat.yml

@@ -51,7 +51,7 @@ datasource:
                   initSqlsGetConnection: true
                 }
   ]
-  datasourceProviderClass: io.mycat.datasource.jdbc.datasourceProvider.DruidDatasourceProvider
+  datasourceProviderClass: io.mycat.datasource.jdbc.datasourceprovider.DruidDatasourceProvider
   timer: {initialDelay: 10, period: 15, timeUnit: SECONDS}
 cluster: #集群,数据源选择器,既可以mycat自行检查数据源可用也可以通过mycat提供的外部接口设置设置数据源可用信息影响如何使用数据源
   close: true  #关闭集群心跳,此时集群认为所有数据源都是可用的,可以通过mycat提供的外部接口设置数据源可用信息达到相同效果

example/src/test/resources/io/mycat/example/pstmt/mycat.yml

@@ -51,7 +51,7 @@ datasource:
                   initSqlsGetConnection: true
                 }
   ]
-  datasourceProviderClass: io.mycat.datasource.jdbc.datasourceProvider.AtomikosDatasourceProvider
+  datasourceProviderClass: io.mycat.datasource.jdbc.datasourceprovider.AtomikosDatasourceProvider
   timer: {initialDelay: 10, period: 5, timeUnit: SECONDS}
 cluster: #集群,数据源选择器,既可以mycat自行检查数据源可用也可以通过mycat提供的外部接口设置设置数据源可用信息影响如何使用数据源
   close: true  #关闭集群心跳,此时集群认为所有数据源都是可用的,可以通过mycat提供的外部接口设置数据源可用信息达到相同效果