文档章节

【数据库中间件】分布式组件 - 中间件客户端连接显示表和数据

Fx_demon
 Fx_demon
发布于 2017/09/06 08:43
字数 559
阅读 37
收藏 1
点赞 0
评论 0

最近项目使用分布式数据库中间件 ,后端数据库使用到Oracle ,使用客户端工具连接 ,发现中间件使用JDBC连接方式连接后端数据库为Oracle、SQL Server /DB2等 不显示表名 ,查询数据必须使用SQL命令窗口执行,但是SQL命令窗口执行SQL时,也不提示表名 字段名 、给开发人员和数据库运维人员带来极大的不便,偷窥一下源码 ,也许这个不是最好的解决,欢迎吐槽和转载 。。。

问题:

用 Navicat Client 、MySQL 客户端 连接数据库中间件(MyCat),中间件连接不显示表名称, 后端数据库是Oracle、DB2等  效果图如下:


    解决方式

涉及类 : JDBCConnection 主要解决Oracle 表显示    【已解决】 需要完善表显示数据和分片节点 后续迁移到 io.mycat.backend.jdbc.oracle.ShowTables中

修个内容:

private void executeSQL(RouteResultsetNode rrn, ServerConnection sc,
                            boolean autocommit) throws IOException {
        String orgin = rrn.getStatement();
        // String sql = rrn.getStatement().toLowerCase();
         LOGGER.debug("JDBC SQL:"+orgin+"|"+sc.toString());
        if (!modifiedSQLExecuted && rrn.isModifySQL()) {
            modifiedSQLExecuted = true;
        }

        try {
            syncIsolation(sc.getTxIsolation()) ;
            if (!this.schema.equals(this.oldSchema)) {
                con.setCatalog(schema);
                this.oldSchema = schema;
            }
            if (!this.isSpark) {
                con.setAutoCommit(autocommit);
            }
            int sqlType = rrn.getSqlType();
             if( rrn.isCallStatement() && "oracle".equalsIgnoreCase(getDbType()))
             {
                 //存储过程暂时只支持oracle
                 ouputCallStatement(rrn,sc,orgin);
             } else if (sqlType == ServerParse.SELECT || sqlType == ServerParse.SHOW) {
                if( (sqlType == ServerParse.SHOW) && (!dbType.equals("MYSQL")) ) {
                    // showCMD(sc, orgin);
                    //ShowVariables.execute(sc, orgin);
                    boolean showExecute = true;
                    if ("SHOW TABLES".equalsIgnoreCase(orgin)){
                         orgin = "SELECT TABLE_NAME FROM  USER_TABLES" ;
                    } else if ("SHOW FULL TABLES WHERE Table_type != 'VIEW'".equalsIgnoreCase(orgin)){
                         orgin = " SELECT OBJECT_NAME,'BASE TABLE' AS Table_type FROM USER_OBJECTS WHERE OBJECT_TYPE='TABLE' ";
                    } else if ("SHOW TABLE STATUS".equalsIgnoreCase(orgin)){
                         StringBuffer sb = new StringBuffer();
                         sb.append(" SELECT  A.TABLE_NAME,A.NUM_ROWS AS \"Rows\",A.LAST_ANALYZED AS Create_time,A.LAST_ANALYZED AS Update_time,");
                         sb.append(" 'InnoDB' AS ENGINE, '' AS Auto_increment ,  B.COMMENTS AS  \"COMMENT\" ");
                         sb.append(" FROM USER_TABLES A, USER_TAB_COMMENTS B WHERE A.TABLE_NAME = B.TABLE_NAME ORDER BY TABLE_NAME ");
                         orgin = sb.toString();
                    } else {
                         showExecute = false;
                    }
                    
                    if( showExecute ){
                        ouputResultSet(sc, orgin);
                    } else {
                        ShowVariables.execute(sc, orgin,this);
                    }    
                } else if ("SELECT CONNECTION_ID()".equalsIgnoreCase(orgin)) {
                    //ShowVariables.justReturnValue(sc,String.valueOf(sc.getId()));
                    ShowVariables.justReturnValue(sc,String.valueOf(sc.getId()),this);
                } else{
                    if("SELECT @@character_set_database, @@collation_database".equalsIgnoreCase(orgin)){
                        orgin = "SELECT * FROM NLS_DATABASE_PARAMETERS WHERE PARAMETER= 'NLS_CHARACTERSET' ";
                    }
                    ouputResultSet(sc, orgin);
                }
            } else {
                executeddl(sc, orgin);
            }

        } catch (SQLException e) {

            String msg = e.getMessage();
            ErrorPacket error = new ErrorPacket();
            error.packetId = ++packetId;
            error.errno = e.getErrorCode();
            error.message = msg.getBytes();
            this.respHandler.errorResponse(error.writeToBytes(sc), this);
        } catch (Exception e) {
            String msg = e.getMessage();
            ErrorPacket error = new ErrorPacket();
            error.packetId = ++packetId;
            error.errno = ErrorCode.ER_UNKNOWN_ERROR;
            error.message = ((msg == null) ? e.toString().getBytes() : msg.getBytes());
            String err = null;
            if(error.message!=null){
                err = new String(error.message);
            }
            LOGGER.error("sql execute error, "+ err , e);
            this.respHandler.errorResponse(error.writeToBytes(sc), this);
        }
        finally {
            this.running = false;
        }

    }

 

© 著作权归作者所有

共有 人打赏支持
Fx_demon
粉丝 6
博文 41
码字总数 14025
作品 0
西安
CTO(技术副总裁)
分布式 dubbo zookeeper springmvc mybatis shiro restful redis fastdfs activemq

摘要: 摘要: SSH ++shiro+restful+bootstrap java架构 java企业架构 spring mvc +mybatis + KafKa+Flume+Zookeeper j2ee分布式架构 dubbo + springmvc + mybatis + ehcache + redis 分布式架......

qq592fbb5b34ad7 ⋅ 2017/06/01 ⋅ 0

现在流行这些:dubbo+zookeeper+springmvc+mybatis+shiro+redis+kafka+bootstrap

平台简介 Jeesz是一个分布式的框架,提供项目模块化、服务化、热插拔的思想,高度封装安全性的Java EE快速开发平台。 Jeesz本身集成Dubbo服务管控、Zookeeper注册中心、Redis分布式缓存技术、...

代码潇洒哥 ⋅ 2017/04/17 ⋅ 1

java企业架构 spring mvc +mybatis + KafKa+Flume+Zookeeper

平台简介 Jeesz是一个分布式的框架,提供项目模块化、服务化、热插拔的思想,高度封装安全性的Java EE快速开发平台。 Jeesz本身集成Dubbo服务管控、Zookeeper注册中心、Redis分布式缓存技术、...

qq58edeba279279 ⋅ 2017/05/17 ⋅ 0

【分享】微服务分布式企业框架 Springmvc+mybatis+shiro+Dubbo+ZooKeeper+Redis+KafKa

框架简介--主要定位于互联网企业架构,已内置企业信息化系统的基础功能和高效的代码生成工具,包括:系统权限组件、数据权限组件、数据字典组件、核心工具 组件、视图操作组件、工作流组件组...

typhoon55 ⋅ 2017/08/23 ⋅ 3

{精华}分布式、微服务、云架构dubbo+zookeeper+springmvc+mybatis+shiro+redis分布式大型互联网企业架构

摘要: Jeesz主要定位于互联网企业架构,已内置企业信息化系统的基础功能和高效的代码生成工具,包括:系统权限组件、数据权限组件、数据字典组件、核心工具 组件、视图操作组件、工作流组件、...

qq593e3b758e013 ⋅ 2017/06/12 ⋅ 0

【推荐】微服务大型分布式企业框架 Springmvc+mybatis+shiro+Dubbo+ZooKeeper+Redis

平台简介 Jeesz是一个分布式的框架,提供项目模块化、服务化、热插拔的思想,高度封装安全性的Java EE快速开发平台。 Jeesz本身集成Dubbo服务管控、Zookeeper注册中心、Redis分布式缓存技术、...

清风徐来l ⋅ 2017/06/09 ⋅ 1

企业大型互联网分布式架构{Java分布式架构 dubbo + springmvc + mybatis + ehcache + redis }

平台简介 Jeesz是一个分布式的框架,提供项目模块化、服务化、热插拔的思想,高度封装安全性的Java EE快速开发平台。 Jeesz本身集成Dubbo服务管控、Zookeeper注册中心、Redis分布式缓存技术、...

qq592fbb5b34ad7 ⋅ 2017/06/07 ⋅ 0

【推荐】微服务大型分布式企业框架 Springmvc+mybatis+shiro+Dubbo+ZooKeeper+Redis+KafKa

平台简介 Jeesz是一个分布式的框架,提供项目模块化、服务化、热插拔的思想,高度封装安全性的Java EE快速开发平台。 Jeesz本身集成Dubbo服务管控、Zookeeper注册中心、Redis分布式缓存技术、...

码上来l ⋅ 2017/06/05 ⋅ 7

精华【分布式、微服务、云架构、dubbo+zookeeper+springmvc+mybatis+shiro+redis】分布式大型互联网企业架构!

平台简介 Jeesz是一个分布式的框架,提供项目模块化、服务化、热插拔的思想,高度封装安全性的Java EE快速开发平台。 Jeesz本身集成Dubbo服务管控、Zookeeper注册中心、Redis分布式缓存技术、...

开心快le每一天 ⋅ 2017/05/26 ⋅ 0

精华分布式、微服务、云架构dubbo+zookeeper+springmvc+mybatis+shiro+redis分布式大型互联网企业架构!

平台简介 Jeesz是一个分布式的框架,提供项目模块化、服务化、热插拔的思想,高度封装安全性的Java EE快速开发平台。 Jeesz本身集成Dubbo服务管控、Zookeeper注册中心、Redis分布式缓存技术、...

qq59225f73c290b ⋅ 2017/05/22 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

Cube、Cuboid 和 Cube Segment

1.Cube (或Data Cube),即数据立方体,是一种常用于数据分析与索引的技术;它可以对原始数据建立多维度索引。通过 Cube 对数据进行分析,可以大大加快数据的查询效率 2.Cuboid 在 Kylin 中特...

无精疯 ⋅ 39分钟前 ⋅ 0

github太慢

1:用浏览器访问 IPAddress.com or http://tool.chinaz.com 使用 IP Lookup 工具获得github.com和github.global.ssl.fastly.net域名的ip地址 2:/etc/hosts文件中添加如下格式(IP最好自己查一...

whoisliang ⋅ 41分钟前 ⋅ 0

非阻塞同步之 CAS

为解决线程安全问题,互斥同步相当于以时间换空间。多线程情况下,只有一个线程可以访问同步代码。这种同步也叫阻塞同步(Blocking Synchronization). 这种同步属于一种悲观并发策略。认为只...

长安一梦 ⋅ 51分钟前 ⋅ 0

云计算的选择悖论如何对待?

人们都希望在工作和生活中有所选择。但心理学家的调查研究表明,在多种选项中进行选择并不一定会使人们更快乐,甚至不会产生更好的决策。心理学家Barry Schwartz称之为“选择悖论”。云计算为...

linux-tao ⋅ 54分钟前 ⋅ 0

我的第一篇个人博客

虽然这是个技术博客,但是,我总是想写一些自己的东西,所有就大胆的在这里写下了第一篇非技术博客。技术博客也很久没有更新,个人原因。 以后自己打算在这里写一些非技术博客,可能个人观点...

Mrs_CoCo ⋅ 55分钟前 ⋅ 0

Redis 注册为 Windows 服务

Redis 注册为 Windows 服务 redis 注册为 windows 服务相关命令 注册服务 redis-server.exe –service-install redis.windows.conf 删除服务 redis-server –service-uninstall 启动服务 re......

Os_yxguang ⋅ 55分钟前 ⋅ 0

世界那么大,语言那么多,为什么选择Micropython,它的优势在哪?

最近国内MicroPython风靡程序界,是什么原因导致它这么火呢?是因为他功能强大,遵循Mit协议开源么? 错!因为使用它真的是太舒服了!!! Micropython的由来,这得益于Damien George这位伟大...

bodasisiter ⋅ 58分钟前 ⋅ 0

docker 清理总结

杀死所有正在运行的容器 docker kill $(docker ps -a -q) 删除所有已经停止的容器(docker rm没有加-f参数,运行中的容器不会删掉) docker rm $(docker ps -a -q) 删除所有未打 dangling 标...

vvx1024 ⋅ 今天 ⋅ 0

关于学习

以前学车的时候,教练说了这样的一句话:如果一个人坐在车上一直学,一直学,反而不如大家轮流着学。因为一个人一直学,就没有给自己留空间来反思和改进。而轮流着学的时候大家下来之后思考上...

mskk ⋅ 今天 ⋅ 0

压缩工具之gzip-bzip2-xz

win下常见压缩工具:rar zip 7z linux下常见压缩工具:zip gz bz2 xz tar.gz tar.bz2 tar.xz gzip 不支持目录压缩 gzip 1.txt #压缩。执行后1.txt消失,生成1.txt.gz压缩文件 gzip -d 1.txt....

ZHENG-JY ⋅ 今天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部