最近项目组在验证一个应用场景,让自己的应用在MySQL和Oracle数据库都能够正常运行(你可以认为我们没事吃饱撑着玩)。首先感谢就是没有用到存储过程,要不真的是要吐血了。其次使用MyBatis来做数据库访问的中间层,才能同时支持MySQL和Oracle,即使如此,这种同时支持也让我们感到行大于知,做比想难。这种差异主要还是因为两种数据库的不同造成应用SQL语句写法上的差异,例如Oracle不允许写双引号的常量如where user_id="123",但是MySQL则是正常,为了兼容,我们需要使用单引号,下面我们把碰到的一些主要问题记录下来,为了能存在自己的记忆中。
1、关于日期类型的操作
由于MySQL在插入yyyy-mm-dd HH:mm:ss格式的日期数据时候,对于映射的数据可以定义为String类型,MySQL驱动会自动将字符串的日期数据转换为MySQL的日期定义格式,但是Oracle则不允许将字符串数据直接映射为Oracle定义的日期列,必须通过SQL语句中使用to_date和to_char函数实现日期和字符的相互转换。这样导致MyBatis中SQL写法的不一致。
为了统一SQL写法,对于映射为日期类型列的Java对应数据需要定义为Date类型,这样在MyBatis做参数映射Bind的时候,两个数据库的驱动都会支持Date类型的Java对象数据插入,从而避免了SQL语句的差别。至于将前端提交的日期字符串数据自动的映射到日期字段,Spring的K/V映射对象需要扩展Convert(String,Data)接口,对于JSON传入的数据,一般JSON解析器可以根据相关的Annotation注释将字符串日期数据转换为Date对象,这需要应用底层支撑.例如fastjson在定义日期对象createDate上通过JSONField定义了日期转字符串的默认格式。
@JSONField(yyyy-MM-dd HH:mm:ss)
Date createDate; //创建时间
2、关于一次插入多记录的操作
MySQL能够方便的将一个List<T>对象中的多条记录通过一条SQL语句插入一张表,提高了整个速度,这种插入和Java的Batch插入多条记录不一致,是一次交互,一条语句搞定,只是Mysql默认对一次交互的SQL语句长度有限制,默认为1M,所以List中的记录条数不能过多,否则报错 nested exception is com.mysql.jdbc.PacketTooBigException: Packet for query is too large (5677854 > 1048576). You can change this value on the server by setting the max_allowed_packet' variable。
另外一种场景,对于EXCEL导入这种业务,如果所有记录当一个事务更新,我们会使用MyBatis的批量机制,类似如下,但是执行的效率肯定没有下面一条语句插入的速度快(见下面的foreach语法),尤其记录数据到5000,10000条的时候,两种处理方式的时间差会更加明显。
SqlSession sqlSession = sqlSessionTemplate.getSqlSessionFactory().openSession(ExecutorType.BATCH, false);
UserDao mapper = sqlSession.getMapper(UserDao.class);
for (int i = 0; i < 500; i++) {
user = new User();
user.setId("test" + i);
user.setName("name" + i);
mapper.insert(user);
}
sqlSession.commit();
由于两个数据库在处理这种多记录插入语句的不同,我们可以充分利用MyBatis的databaseId这个属性,通过if等表达式,在xml文件中,通过databaseId执行不同的sql语句,这可以作为跨数据库通用的解决方案。注意这种批量插入的记录数据的写法,记录数不能过多,避免超过单条SQL语句的长度,大家可以猜猜_databaseId这个属性怎么配置来(度娘肯定知道)。
对于我们而言,需要明白MyBatis加载如下定义和上述定义的区别,下面的配置代表初始化过程会根据连接数据库种类的不同,优先加载与该数据库种类匹配的语句定义,在连接ORACLE数据的时候,将不加载此文件。
3.关于数据库翻页记录的操作
这个应该是两最明显的区别了,很多人都知道MySql中分页很简单,因为它利用关键字limit来实现分页查询;但是Oracle实现起来就比MySql要繁琐得多了,在每个结果集中只有一个rownum字段标明它的位置,并且只能用rownum<=某个数,不能用rownum>=某个数,因为ROWNUM是伪列,在使用时所以需要为ROWNUM取一个别名,变成逻辑列,然后来操作。例如:
select * from (select ROWNUM as num,A.* from (select * from testtable) A where ROWNUM<=40) where num >= 20;
由于两个数据库对于翻页语句处理的不同,虽然我们可以利用databaseId关键字写出两种不同的翻页语句,而且必然是两条语句,一条查出符合条件的记录总数,所以代码实现会有一定的复杂和重复读。所以更多的时候,应用会扩展MyBatis的插件Plugin机制,对StamentHandler对象进行拦截,根据开发人员传入的select语句,自动匹配数据库的种类,完成翻页记录总数据的查询,这种机制根据传入的select语句抽取,得出总的toatal记录数,然后再自动组装翻页语句,简化了应用开发,只是查询总数和封装翻页对象的过程交给了基础组件,也屏蔽了数据库的差异。
以上几种场景是目前我们在使用MyBatis跨平台使用过程中碰到的问题,在没有实践之前,总以为没有存储过程使用,就可以很快在ORACLE和MySQL之间转换,其实不然,还有较多细节需要关注,底层框架也需要扩展,尤其在翻页交易场景中。其实在真正上线过程中,应用可能还会扩展Plugin机制,记录超过指定执行时间或者结果集的SQL语句,以协助应用和数据库之间发生问题时的场景分析。