- 浏览: 41346 次
- 性别:
- 来自: 武汉
文章分类
最新评论
一劳永逸的数据库编码解决方案
问题提出
现在几乎所有的应用系统都无法避免使用数据库系统。在JAVA世界里访问数据库是一件非常轻松的事情,JDBC为JAVA应用程序访问数据库提供了一个统一的接口,通过使用JDBC接口开发者无需关心系统最终采用哪种数据库,因为JDBC仅仅是定义了访问几个JAVA的接口类,具体的实现是由数据库厂商提供的,这种做法其实与其他数据库连接方式例如ODBC是类似的。但是在实际的应用过程中,开发者发现离JDBC设计的初衷还是有一定距离,就比如说在存储字符串时的编码问题,我想很多开发者都会遇见这个问题,倒不是因为说解决它有什么技术方面的难度,而是它的的确确非常繁琐。我们必须在每次写入或者读出字符串的时候进行编码和反编码处理;或者说我们可以写一个方法可以进行编码处理的,但又必须在每次数据库操作的时候调用,虽然调用很简单,可是我非得这样吗?要是忘了编码那又要DEBUG了。当然你可能觉得这并没有什么,或者你可能很勤快,喜欢写大量重复的代码,可是你难道没有觉得这种繁琐的工作正在浪费你过于宝贵的青春吗?停止你的键盘输入,让我们来解决这个问题吧!
解决思路
在传统的应用程序中数据库操作部分我们可以想象成两层,如图所示:一个是数据库的“连接池”,另外一个业务数据操作层。在这里数据库的连接池是广义的,你可以把JDBC中的DriverManager也当成是连接池,具体的意思就是我们可以通过这层来获取到指定数据库的连接而不去关心它是怎么获取的。如果这个时候数据库系统(有如Informix,SQL Server)要求对字符串进行转码才能存储(例如最常见的GBK->ISO8859_1转码),那我们就必须在业务数据操作层来进行,这样有多少业务数据操作我们就要做多少编码转码的工作,太麻烦了,代码中充斥中大量重复的内容。本文提出的解决方案就是利用对获取到的数据库连接实例进行二次封装,也就是在数据库连接池与业务数据操作层之间加入了连接封装层,当然了,我们也完全可以直接将连接封装集成到数据库连接池内部。
我们知道进行编码和转码工作都是集中在JDBC的两个接口PreparedStatement和ResultSet上进行的,主要涉及PreparedStatement的setString方法以及ResultSet的getString方法。前面我们讲过需要加入一个连接封装层来对数据库连接实例进行二次封装,但是怎么通过这个封装来改变PreparedStatement和ResultSet这两个接口的行为呢?这个问题其实也很简单,因为PreparedStatement接口必须通过Connection接口来获取实例,而ResultSet接口又必须从Statement或者PreparedStatement接口来获取实例,有了这样的级联关系,问题也就迎刃而解了。还是利用我在文章《使用JAVA动态代理实现数据库连接池》中使用的动态接口代理技术。首先我们设计Connection接口的代理类_Connection,这个代理类接管了Connection接口中所有可能获取到Statement或者PreparedStatement接口实例的方法,例如:prepareStatement和createStatement。改变这两个方法使之返回的是经过接管后的Statement或者PreparedStatement实例。通过对于Statement接口也有相应的代理类_Statement,这个代理类接管用于获取ResultSet接口实例的所有方法,包括对setString方法的接管以决定是否对字符串进行编码处理。对于接口ResultSet的接管类_ResultSet就相应的比较简单,它只需要处理getString方法即可。
关键代码
前面我们大概介绍了这个解决方案的思路,下面我们给出关键的实现代码包括Connection的代理类,Statement的代理类,ResultSet的代理类。这些代码是在原来关于数据库连接池实现的基础上进行扩充使之增加对自动编码处理的功能。有需要源码打包的可以通过电子邮件跟我联系。
_Connection.java
/* * Created on 2003-10-23 by Liudong */ package lius.pool;
import java.sql.*;
import java.lang.reflect.*;
/** * 数据库连接的代理类 * @author Liudong */ class _Connection implements InvocationHandler { private Connection conn = null; private boolean coding = false;//指定是否进行字符串转码操作
_Connection(Connection conn, boolean coding){ this.conn = conn; this.coding = coding; initConnectionParam(this.conn); }
/** * Returns the conn. * @return Connection */ public Connection getConnection() { Class[] interfaces = conn.getClass().getInterfaces(); if(interfaces==null||interfaces.length==0){ interfaces = new Class[1]; interfaces[0] = Connection.class; } Connection conn2 = (Connection)Proxy.newProxyInstance( conn.getClass().getClassLoader(), interfaces,this); return conn2; }
/** * @see java.lang.reflect.InvocationHandler#invoke */ public Object invoke(Object proxy, Method m, Object[] args) throws Throwable { String method = m.getName(); //调用相应的操作 Object obj = null; try{ obj = m.invoke(conn, args); //接管用于获取语句句柄实例的方法 if((CS.equals(method)||PS.equals(method))&&coding) return new _Statement((Statement)obj,true).getStatement(); }catch(InvocationTargetException e){ throw e.getTargetException(); } return obj; }
private final static String PS = "prepareStatement"; private final static String CS = "createStatement";
} |
_Statement.java
/* * Created on 2003-10-23 by Liudong */ package lius.pool;
import java.sql.*; import java.lang.reflect.*;
/** * 数据库语句对象实例的代理类 * @author Liudong */ class _Statement implements InvocationHandler { private Statement statement ; //保存所接管对象的实例 private boolean decode = false; //指定是否进行字符串转码
public _Statement(Statement stmt,boolean decode) { this.statement = stmt; this.decode = decode; } /** * 获取一个接管后的对象实例 * @return */ public Statement getStatement() { Class[] interfaces = statement.getClass().getInterfaces(); if(interfaces==null||interfaces.length==0){ interfaces = new Class[1]; interfaces[0] = Statement.class; } Statement stmt = (Statement)Proxy.newProxyInstance( statement.getClass().getClassLoader(), interfaces,this); return stmt; } /** * 方法接管 */ public Object invoke(Object proxy, Method m, Object[] args) throws Throwable { String method = m.getName(); //接管setString方法 if(decode && SETSTRING.equals(method)){ try{ String param = (String)args[1]; if(param!=null) param = new String(param.getBytes(),”8859_1”); return m.invoke(statement,new Object[]{args[0],param}); }catch(InvocationTargetException e){ throw e.getTargetException(); } } //接管executeQuery方法 if(decode && EXECUTEQUERY.equals(method)){ try{ ResultSet rs = (ResultSet)m.invoke(statement,args); return new _ResultSet(rs,decode).getResultSet(); }catch(InvocationTargetException e){ throw e.getTargetException(); } } try{ return m.invoke(statement, args); }catch(InvocationTargetException e){ throw e.getTargetException(); } } //两个要接管的方法名 private final static String SETSTRING = "setString"; private final static String EXECUTEQUERY = "executeQuery"; }
|
_ResultSet.java
/* * Created on 2003-10-23 by Liudong */ package lius.pool;
import java.sql.ResultSet;
import java.lang.reflect.InvocationHandler; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; import java.lang.reflect.Proxy;
/** * 数据库结果集的代理类 * @author Liudong */ class _ResultSet implements InvocationHandler { private ResultSet rs = null; private boolean decode = false;
public _ResultSet(ResultSet rs,boolean decode) { this.rs = rs; this.decode = decode; }
public ResultSet getResultSet(){ Class[] interfaces = rs.getClass().getInterfaces(); if(interfaces==null||interfaces.length==0){ interfaces = new Class[1]; interfaces[0] = ResultSet.class; } ResultSet rs2 = (ResultSet)Proxy.newProxyInstance( rs.getClass().getClassLoader(), interfaces,this); return rs2; }
/** * 结果getString方法 */ public Object invoke(Object proxy, Method m, Object[] args) throws Throwable { String method = m.getName(); if(decode && GETSTRING.equals(method)){ try{ String result = (String)m.invoke(rs,args); if(result!=null) return new String(result.getBytes(“8859_1”)); return null; }catch(InvocationTargetException e){ throw e.getTargetException(); } } try{ return m.invoke(rs, args); }catch(InvocationTargetException e){ throw e.getTargetException(); } } private final static String GETSTRING = "getString"; }
|
现在我们已经把三个接口的代理类做好了,下一步就是怎么来使用这三个类。其实对于使用者来讲并不需要关心三个类,只需要了解_Connection就可以了,因为另外两个是_Connection直接调用的。为了使用_Connection我们必须传入两个参数,第一个是数据库实际的数据库连接实例,另外一个是布尔值代表是否进行转码处理。我们必须先通过实际的情况获取到数据库连接后再传入_Connection的构造函数作为参数,下面例子告诉你如何来使用_Connection这个类:
Connection conn = getConnection();//获取数据库连接 boolean coding = false;//从配置或者其他地方读取是否进行转码的配置 //接管数据库连接实例 _Connection _conn = new _Connection(conn,coding); //获得接管后的数据库连接实例,以后直接使用conn2而不是conn Connection conn2 = _conn.getConnection();
|
因为对一个应用系统来讲,数据库连接的获取必然有统一的方法,在这个方法中加入对连接的接管就可以一劳永逸的解决数据库的编码问题。
性能比较
功能没有问题了,开发者接下来就会关心性能的问题,因为在进行一些对响应速度要求很高或者大数据量的处理情况下性能就成为一个非常突出的问题。由于JAVA中的动态接口代理采用的是反射(Reflection)机制,同时又加入我们自己的一些代码例如方法名判断,字符串转码等操作因此在性能上肯定比不上直接使用没有经过接管的数据库连接。但是这点性能上的差别是不是我们可以忍受的呢,为此我做了一个试验对二者进行了比较:
测试环境简单描述:
使用ACCESS数据库,建两张结构一样的表,计算从获取连接后到插入数据完毕后的时间差,两个程序(直连数据库和使用连接接管)都进行的字符串的转码操作。
测试结果:
插入记录数 |
直连数据库程序耗时 单位:ms |
使用连接接管程序耗时 |
性能比较 |
1000 |
2063 |
2250 |
9.0% |
5000 |
8594 |
8359 |
-2.7% |
10000 |
16750 |
17219 |
2.8% |
15000 |
22187 |
23000 |
3.6% |
20000 |
27031 |
27813 |
2.9% |
从上面这张测试结果表中来看,二者的性能的差别非常小,尽管在两万条数据的批量插入的时候时间差别也不会多于一秒钟,这样的结果应该说还是令人满意的,毕竟为了程序良好的结构有时候牺牲一点点性能还是值得的。
发表评论
-
java 综合
2012-05-11 17:34 2261身份证:18位判断数,15位的转换成18位,把地区码提出 ... -
JAVA设计模式之工厂模式
2012-05-11 17:33 825JAVA设计模式之工厂模式 一、工厂模式的介绍 工厂 ... -
ANT 自动编译打包发布卸载脚本
2010-12-03 10:04 1311网上看了很多此类脚本,要不就是太简单,要不就是太复杂 ... -
JDBC查询
2010-10-27 11:25 1821BaseDB类: package com.framework ... -
MyEclipse7.5详细优化+快捷键的使用
2010-05-25 11:09 1410相信大家在启动MyEclipse的时候都很慢,很烦有没有让他更 ... -
Log4j基本使用方法
2010-05-18 10:51 690Log4j由三个重要的组件 ... -
java与c#中二维数组的区别
2010-05-18 10:43 982java与c#中二维数组的区别[color=green][/c ...
相关推荐
鉴于以上情况,此程序为广大站长提供了完善的 MSSql 数据库备份解决方案。它可以定时地对设置的 MSSql 数据库进行备份,并将备份后的文件通过 FTP 传输到本地计算机。 1、多线程,支持断点续传。 2、开机启动 + ...
通常我都会尽量避免对业内游戏产品或开发者们评头论足。 但这回我不得不破一次例。 我要讨论一些关于寻路的问题。为了证明这些问题至今仍然存在,我本着娱乐的精神制 作了这个视频。 (译注:原视频缺失。...
V2017版重要更新: 1、播放器开启速度大幅度提高; 2、新增U盘和移动硬盘召回功能; 3、增加文件关联功能,加密后的视频可以自动关联到播放器,双击视频即可打开; 4、可以自定义个性化认证界面图,专业的认证界面...
一,改数据库编码以下两种方案任选一ps: 修改数据库配置可以一劳永逸,直接sql修改当机器重启时新加的设置会被还原1.修改数据库配置文件windows下的my.
access数据库连接VB.NET类库,将VB.NET和数据库无缝连接,之后调用数据库直接调用函数名,一劳永逸!
一劳永逸VMware6个经典技巧
彻底告别手动写SQL语句,一劳永逸解决数据库字段变更后代码也需要随之修改的问题。 根据DataTable中数据行记录改变的状态,动态生成SQL语句, 如果一个表中字段上百个,在只改了其中两三个字段时,则生成的SQL语句...
去掉快捷方式箭头完美解决方案,用透明ico图标替换,一劳永逸。
数据库定时自动备份,可以一劳永逸,对新手是最好的帮主。防止数据丢失
一劳永逸 把Excel表格搬到网上tnndsdlfjaef
go语言AI反电销骚扰系统源码解决电话骚扰问题的AI解决方案。采用Golang语言开发,自带新手向导,开箱即用。实现功能:智能接听: 识别对方的语音,配合您的话术设置判断是否骚扰行为(比如设置拒接"贷款、中介、炒股...
政府网络安全解决方案 以Internet为代表的全球性信息化浪潮日益深刻,信息网络技术的应用正日益普及和广 泛,应用层次正在深入,应用领域从传统的、小型业务系统逐渐向大型、关键业务系统 扩展,典型的如行政部门...
面对着猖獗的盗版,为了防止软件的非法复制、盗版,保护软件作者或者...你只需使用SDProtector软件的产品就可以一劳永逸的解决这个问题。可以帮你节省了时间、精力和金钱,最大可能地扩大你的客户群,增加了你的收益。
一劳永逸解决个版本visio无法形状搜索问题,操作简单不修改表
电商CMS,一劳永逸的建站方案.docx
一劳永逸让VB自动改变控件大小 Private Sub Form_Load()//初始化设置 Picture1.AutoSize = True Command1.Caption = ″显示网格″ Command2.Caption = ″取消网格″ Form1.Caption = ″显示网格图像演示程序...
java源码六子棋游戏代码解决方案的出现 这个 repo 包含我所有(当前)解决的代码挑战。 我将随时使用其他解决方案更新 repo。 如何 克隆回购 将其作为 maven 项目导入到您的 IDE 每天运行自包含类(确保替换每个输入...
解决开机按F1才能进入系统的问题,一劳永逸。.docx
包括全部数据流程图,数据字典,完整版ER图,附加亿图绘图时使用的图形库,数据库包括完整dmp文件,答辩论文和实施计划书,只做简单修改就可一劳永逸,主要针对解决大学数据库实习难题,快速理清头绪,方便学习参考...
Protel99SE(SP6),体积小,经典...现在使用本超级补丁摒弃了以前导入库助手每次都需操作的方式,可一劳永逸地解决导入库文件及Format %x问题! (简单粗暴的来说,其实下载别人打过补丁的Protel99SE文件直接覆盖就行了)