mycat源码解读-凯发k8国际

gaojingsong

浏览: 1124912 次
性别:
来自: 深圳

博主相关

博客

微博

相册

文章分类

社区版块

( 4)
( 0)
( 80)

存档分类

2023-12 ( 2)
2021-12 ( 1)
2021-10 ( 2)

mycat源码解读--错误之【can't find table define in schema 】

博客分类：

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());

}

//此处省略如下代码

}

0
顶

0
踩

分享到：

2017-03-01 20:30
浏览 11075
评论(1)
分类:开源软件

1 楼 hdd901002 2018-05-17

光说明错误在哪里有什么用，解决方法啊。。。
我也碰到了，一条join语句，后来两张表join先后调换位置就好了

发表评论

您还没有登录,请您登录后再发表评论