Mycat适配oracle，各种坑 - HelloWorld开发者社区

注：文中使用版本为Mycat 1.6.5。

1、Mycat

正如官方所说，

Mycat 是数据库中间件，就是介于数据库与应用之间，进行数据处理与交互的中间服务。由于前面讲的对数据进行分片处理之后，从原有的一个库，被切分为多个分片数据库，所有的分片数据库集群构成了整个完整的数据库存储。

当然，Mycat没有自己的存储引擎，并不是完全意义的分布式数据库系统。

以下是官方的架构图。

Mycat适配oracle，各种坑

我们可以清晰地看到MyCat的核心是“拦截sql并做解析、路由，结果集合并”。

但是，也如官方所设计的

Mycat 就是MySQL 最佳伴侣，它在一定程度上让MySQL 拥有了能跟Oracle PK 的能力。

MyCat的基因从Cobar开始，就是为MySQL为设计的。当你使用oracle作为物理库的时候，就会出现各种问题。

2、SQL解析问题

不论原有Mycat不支持的SQL语句，但oracle语法就很多不兼容，甚至无法正常运行。如insert into .... select ...语句不支持；blob大字段的insert/update在oracle环境有问题；不支持start with ... connect by....递归树语句；

如果你的系统有这些，要么在应用端改写掉，要么请放弃使用Mycat。

3、select count(1) from xxxx

默认查询，如果是多分片，这个结果会返回多条记录，每天记录是单一个分片的执行结果。

如果需要Mycat合并结果集，需要修改server.xml 的属性：

useOffHeapForMerge=0

另，如果schema设置了sqlMaxLimit，而物理库中结果记录远大于此值，那么你查询的结果会总是不超过sqlMaxLimit。这是一个BUG。

4、Mybatis的批量insert/update

如果你的系统有mybatis对于Oracle环境下进行批量的insert或者update，那么对不起。

Mycat 不能很好识别和解析begin ... insert.... end 语句。

5、调用存储过程

恩，你没看错，不支持CallableStatement方式调用存过。得换Mycat自己的写法，而且还有限制。

// create or replace procedure p_test(return_result out varchar,--返回结果，如果没有费用返回空字符串
      // err_code out number,--异常编码
      // err_msg out varchar,--异常消息
      // p_order_item_id in varchar, --订单标识
      // p_prod_offer_id in number
      // ) as
      // begin
      // err_code:='0';
      // err_msg:='';
      //
      // return_result:=0;
      //
      // exception
      // when dup_val_on_index then
      // err_code:= sqlcode;
      // err_msg:=sqlerrm;
      // when others then
      // err_code:=sqlcode;
      // err_msg:=sqlerrm;
      // end p_test;

      String sql =
          "/*#mycat: sql=SELECT 1 FROM customer_order where cust_id='90000000000' */set @p_order_item_id='',@p_prod_offer_id=0; call p_test (@return_result,@err_code,@err_msg,@p_order_item_id,@p_prod_offer_id);select @return_result,@err_code,@err_msg";

      ps = conn.prepareStatement(sql);
      ps.executeUpdate(); 
      rs = ps.getResultSet();
      if (rs != null) {
        while (rs.next()) {
          String returnVal = rs.getString(1);
          Integer returnVal2 = rs.getInt(2);
          String returnVal3= rs.getString(3);
          System.out.println(returnVal);
          System.out.println(returnVal2);
          System.out.println(returnVal3);
        }
      }