前段時間把 ShardingSphere 升級到了 5.1.1 版本嚎于，奈何官方版本升級太快跟不上速度私沮，這不最近又發(fā)現(xiàn)了一個 BUG憎亚。
問題現(xiàn)象
數(shù)據(jù)庫做了分庫分表衙耕，在需要查詢多表數(shù)據(jù)進行 merge 的時候發(fā)生了一個 NPE 的異常。
Caused by: java.lang.NullPointerException
at org.apache.shardingsphere.sharding.merge.dql.orderby.OrderByValue.getOrderValuesCaseSensitiveFromTables(OrderByValue.java:73) ~[shardingsphere-sharding-core-5.1.1.jar:5.1.1]
at org.apache.shardingsphere.sharding.merge.dql.orderby.OrderByValue.getOrderValuesCaseSensitive(OrderByValue.java:64) ~[shardingsphere-sharding-core-5.1.1.jar:5.1.1]
at org.apache.shardingsphere.sharding.merge.dql.orderby.OrderByValue.<init>(OrderByValue.java:58) ~[shardingsphere-sharding-core-5.1.1.jar:5.1.1]
at org.apache.shardingsphere.sharding.merge.dql.orderby.OrderByStreamMergedResult.orderResultSetsToQueue(OrderByStreamMergedResult.java:56) ~[shardingsphere-sharding-core-5.1.1.jar:5.1.1]
at org.apache.shardingsphere.sharding.merge.dql.orderby.OrderByStreamMergedResult.<init>(OrderByStreamMergedResult.java:50) ~[shardingsphere-sharding-core-5.1.1.jar:5.1.1]
at org.apache.shardingsphere.sharding.merge.dql.ShardingDQLResultMerger.build(ShardingDQLResultMerger.java:89) ~[shardingsphere-sharding-core-5.1.1.jar:5.1.1]
at org.apache.shardingsphere.sharding.merge.dql.ShardingDQLResultMerger.merge(ShardingDQLResultMerger.java:63) ~[shardingsphere-sharding-core-5.1.1.jar:5.1.1]
at org.apache.shardingsphere.infra.merge.MergeEngine.executeMerge(MergeEngine.java:90) ~[shardingsphere-infra-merge-5.1.1.jar:5.1.1]
at org.apache.shardingsphere.infra.merge.MergeEngine.merge(MergeEngine.java:80) ~[shardingsphere-infra-merge-5.1.1.jar:5.1.1]
at org.apache.shardingsphere.driver.jdbc.core.statement.ShardingSpherePreparedStatement.mergeQuery(ShardingSpherePreparedStatement.java:487) ~[shardingsphere-jdbc-core-5.1.1.jar:5.1.1]
at org.apache.shardingsphere.driver.jdbc.core.statement.ShardingSpherePreparedStatement.getResultSet(ShardingSpherePreparedStatement.java:435) ~[shardingsphere-jdbc-core-5.1.1.jar:5.1.1]
at org.apache.ibatis.executor.resultset.DefaultResultSetHandler.getFirstResultSet(DefaultResultSetHandler.java:237) ~[mybatis-3.5.3.jar:3.5.3]
at org.apache.ibatis.executor.resultset.DefaultResultSetHandler.handleResultSets(DefaultResultSetHandler.java:187) ~[mybatis-3.5.3.jar:3.5.3]
at org.apache.ibatis.executor.statement.PreparedStatementHandler.query(PreparedStatementHandler.java:65) ~[mybatis-3.5.3.jar:3.5.3]
at org.apache.ibatis.executor.statement.RoutingStatementHandler.query(RoutingStatementHandler.java:79) ~[mybatis-3.5.3.jar:3.5.3]
at org.apache.ibatis.executor.SimpleExecutor.doQuery(SimpleExecutor.java:63) ~[mybatis-3.5.3.jar:3.5.3]
at org.apache.ibatis.executor.BaseExecutor.queryFromDatabase(BaseExecutor.java:324) ~[mybatis-3.5.3.jar:3.5.3]
at org.apache.ibatis.executor.BaseExecutor.query(BaseExecutor.java:156) ~[mybatis-3.5.3.jar:3.5.3]
at org.apache.ibatis.executor.CachingExecutor.query(CachingExecutor.java:109) ~[mybatis-3.5.3.jar:3.5.3]
at jdk.internal.reflect.GeneratedMethodAccessor346.invoke(Unknown Source) ~[?:?]
at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
at java.lang.reflect.Method.invoke(Method.java:566) ~[?:?]
at org.apache.ibatis.plugin.Plugin.invoke(Plugin.java:63) ~[mybatis-3.5.3.jar:3.5.3]
at com.sun.proxy.$Proxy410.query(Unknown Source) ~[?:?]
at com.github.pagehelper.PageInterceptor.intercept(PageInterceptor.java:108) ~[pagehelper-5.1.11.jar:?]
at org.apache.ibatis.plugin.Plugin.invoke(Plugin.java:61) ~[mybatis-3.5.3.jar:3.5.3]
at com.sun.proxy.$Proxy410.query(Unknown Source) ~[?:?]
at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:147) ~[mybatis-3.5.3.jar:3.5.3]
at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:140) ~[mybatis-3.5.3.jar:3.5.3]
at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:?]
at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
at java.lang.reflect.Method.invoke(Method.java:566) ~[?:?]
at org.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessionTemplate.java:427) ~[mybatis-spring-2.0.6.jar:2.0.6]
... 95 more
問題排查
跟蹤到報錯的地方凡壤，發(fā)現(xiàn)是這個地方的schema是個null，從而引發(fā)了 NPE耙替。
一路往上看代碼亚侠，最終定位到了這個獲取schema的地方，也就是元數(shù)據(jù)去getDefaultSchema獲取默認的schema名稱改的時候拿到了一個空值俗扇。
進入這個方法后發(fā)現(xiàn)通過schema去schemas這個map里獲取名稱的時候是個空值硝烂，debug到這個地方其實發(fā)現(xiàn)了問題。
我們的schemaName配置的是orderTrade包含有大寫字符的铜幽，所以name傳進來的是orderTrade滞谢，但是問題是這個schemas確是ordertrade。
所以很顯然除抛，這里獲取不到正確的schema名稱狮杨，導(dǎo)致了這個 NPE 的異常，那么問題是這個schemas是怎么加載進來的呢到忽？
我們發(fā)現(xiàn)schemas是在創(chuàng)建元數(shù)據(jù)的時候橄教，通過構(gòu)造函數(shù)賦值的，那么只要找到這個賦值的地方應(yīng)該就能發(fā)現(xiàn)問題了喘漏。
通過一番查找护蝶，找到了調(diào)用的地方，這個schemas值就是databaseMap中的value翩迈，那么我們要繼續(xù)看這個databaseMap是如何初始化來的持灰。
繼續(xù)看源碼，找到了databaseMap進行初始化的地方负饲，原來是通過DatabaseLoader去加載元數(shù)據(jù)的時候初始化的堤魁，那么這個load方法是怎么處理的呢喂链？
從代碼來看他包含了兩部分的信息，第一個是我們自己通過schema配置的一些分庫分表的配置信息姨涡，另外一部分則是數(shù)據(jù)庫默認的一些表的元數(shù)據(jù)衩藤，比如mysql、information_schema這些涛漂，那我們只要看自己配置的那部分就可以了赏表，也就是SchemaLoader.load(dataSourceMap, rules, props)方法。
看他實際上就是獲取數(shù)據(jù)庫是什么類型匈仗，比如mysql瓢剿，然后去加載表的元數(shù)據(jù)，最后new出來ShardingSphereSchema悠轩，直接看最后的new部分代碼就行了间狂。
進入這個方法，瞬間就真相大白了火架，原來在put的時候?qū)λ械?code>schemaName進行了小寫處理鉴象，所以在最上面我們?nèi)?code>get的時候肯定會拿到一個空值，最終導(dǎo)致merge的時候發(fā)生了 NPE 異常何鸡。
解決方案
現(xiàn)在問題原因已經(jīng)發(fā)現(xiàn)了纺弊，那么該如何解決呢？總不能不讓別人配置的時候不讓寫大寫吧骡男，本著能不能白嫖一個 PR 的想法淆游，又去給 Sharding 提了一個 Issue。
就我點了根煙的功夫隔盛，回頭就給我回復(fù)說新版本已經(jīng)修復(fù)了犹菱，希望落空了，修復(fù)方案就是查詢的時候也做小寫處理了吮炕，好吧腊脱，那就這樣吧。
