mycat源码解读-买球官网平台

mycat之string msg = "can't find table define in schema " tablename " schema:" schema.getname();

错误位置如下：routerutil 类中的tryroutefortables方法

1、正常情况可以查询数据

 2、别名查询出现错误

 mycat 怎么就通过不了呢

 

 

2017-03-01 20:13:19,812 [warn ][$_nioreactor-2-rw] serverconnection [id=4, schema=testdb, host=127.0.0.1, user=root,txisolation=3, autocommit=true, schema=testdb]select address as address  from `t_gaojs` err:java.sql.sqlnontransientexception: can't find table define in schema address schema:testdb java.sql.sqlnontransientexception: can't find table define in schema address schema:testdb    

at io.mycat.route.util.routerutil.tryroutefortables(routerutil.java:1002)

at io.mycat.route.parser.druid.impl.druidselectparser.tryroute(druidselectparser.java:412)

at io.mycat.route.parser.druid.impl.druidselectparser.changesql(druidselectparser.java:287)

at io.mycat.route.parser.druid.impl.defaultdruidparser.parser(defaultdruidparser.java:67)

找到报错原因 ---》 表名字解析错误

 错误位置：

routerutil 类中的tryroutefortables方法

 

      /**

          * 多表路由

         */

       public static routeresultset tryroutefortables(schemaconfig schema, druidshardingparseinfo ctx,

                    routecalculateunit routeunit, routeresultset rrs, boolean isselect, 

                        layercachepool cachepool)

                   throws sqlnontransientexception {

 

              list tables = ctx.gettables();

 

          if(schema.isnosharding()||(tables.size() >= 1&&isnosharding(schema,tables.get(0)))) {

              return routetosinglenode(rrs, schema.getdatanode(), ctx.getsql());

         }

 

        //只有一个表的

        if(tables.size() == 1) {

                return routerutil.tryrouteforonetable(schema, ctx, routeunit, 

                        tables.get(0), rrs, isselect, cachepool);

          }

 

         set retnodesset = new hashset();

         //每个表对应的路由映射

         map> tablesroutemap = new hashmap>();

 

        //分库解析信息不为空

          map>> tablesandconditions =                       routeunit.gettablesandconditions();

       if(tablesandconditions != null && tablesandconditions.size() > 0) {

             //为分库表找路由

            routerutil.findroutewithcconditionsfortables(schema, rrs, tablesandconditions, 

                                         tablesroutemap, ctx.getsql(), cachepool, isselect);

          if(rrs.isfinishedroute()) {

                  return rrs;

          }

   }

 

//为全局表和单库表找路由

      for(string tablename : tables) {

            tableconfig tableconfig = schema.gettables().get(tablename.touppercase());

          if(tableconfig == null) {

string msg = "can't find table define in schema " tablename " schema:" schema.getname();

          logger.warn(msg);

         throw new sqlnontransientexception(msg);

     }

        if(tableconfig.isglobaltable()) {//全局表

            if(tablesroutemap.get(tablename) == null) {

                  tablesroutemap.put(tablename, new hashset());

              }

           tablesroutemap.get(tablename).addall(tableconfig.getdatanodes());

     } else if(tablesroutemap.get(tablename) == null) { //余下的表都是单库表

             tablesroutemap.put(tablename, new hashset());

            tablesroutemap.get(tablename).addall(tableconfig.getdatanodes());

       }

}

             //此处省略如下代码

               

}