实现高效易用的java操作mysql包装

核心提示：为了简化一些操作，同时为了能兼容其他数据库，实现高效易用的java操作mysql包装，因此并没用使用SqlHelper的形式，这只是个简单模型的开发方式，首先申明数据库接口，这代表了一个数据库能进行的操作，没用纳入数据连接池等内容，我看了网上大部分的SqlHelper在类型转换方面都很有问题

为了简化一些操作，同时为了能兼容其他数据库，因此并没用使用SqlHelper的形式。

这只是个简单模型的开发方式，没用纳入数据连接池等内容。

我看了网上大部分的SqlHelper在类型转换方面都很有问题，而且返回结果使用ArrayList包装了一下。在这里的包装主要是为了避免这两个问题。

首先申明数据库接口，这代表了一个数据库能进行的操作。

package　dao;
import　java.sql.SQLException;
public　interface　Database　{
　　　　int　ExecuteNoneQuery(String　cmdtext,　Parameters　parms)　throws　SQLException;
　　　　<T>　T　ExecuteObject(Data2Object<T>　convertor,　String　cmdtext,
　　　　　　　　　　　　Parameters　parms)　throws　SQLException;
　　　　Object　ExecuteScalar(String　cmdtext,　Parameters　parms)　throws　SQLException;
　　　　Parameters　CreateFixedParms(int　size);
}

实现该接口的MySql包装形式，其实和SqlHelper差不多：

package　dao;
import　java.sql.Connection;
import　java.sql.Date;
import　java.sql.DriverManager;
import　java.sql.PreparedStatement;
import　java.sql.ResultSet;
import　java.sql.SQLException;
public　class　MySqlDatabase　implements　Database　{
　　　　private　Connection　conn;
　　　　public　MySqlDatabase(String　connString)　throws　SQLException　{
　　　　　　　　conn　=　DriverManager.getConnection(connString);
　　　　}
　　　　public　int　ExecuteNoneQuery(String　cmdtext,　Parameters　parms)
　　　　　　　　　　　　throws　SQLException　{
　　　　　　　　PreparedStatement　pstmt　=　null;
　　　　　　　　try　{
　　　　　　　　　　　　pstmt　=　conn.prepareStatement(cmdtext);
　　　　　　　　　　　　prepareCommand(pstmt,　parms);
　　　　　　　　　　　　return　pstmt.executeUpdate();
　　　　　　　　}　catch　(Exception　ex)　{
　　　　　　　　}　finally　{
　　　　　　　　　　　　if　(pstmt　!=　null)　{
　　　　　　　　　　　　　　　　pstmt.clearParameters();
　　　　　　　　　　　　　　　　pstmt.close();
　　　　　　　　　　　　}
　　　　　　　　　　　　if　(conn　!=　null)
　　　　　　　　　　　　　　　　conn.close();
　　　　　　　　}
　　　　　　　　return　-1;
　　　　}
　　　　public　<T>　T　ExecuteObject(Data2Object<T>　convertor,　String　cmdtext,
　　　　　　　　　　　　Parameters　parms)　throws　SQLException　{
　　　　　　　　PreparedStatement　pstmt　=　null;
　　　　　　　　ResultSet　rs　=　null;
　　　　　　　　try　{
　　　　　　　　　　　　pstmt　=　conn.prepareStatement(cmdtext);
　　　　　　　　　　　　prepareCommand(pstmt,　parms);
　　　　　　　　　　　　rs　=　pstmt.executeQuery();
　　　　　　　　　　　　return　convertor.DataMap(rs);
　　　　　　　　}　catch　(Exception　ex)　{
　　　　　　　　}　finally　{
　　　　　　　　　　　　if　(rs　!=　null)
　　　　　　　　　　　　　　　　rs.close();
　　　　　　　　　　　　if　(pstmt　!=　null)
　　　　　　　　　　　　　　　　pstmt.close();
　　　　　　　　　　　　if　(conn　!=　null)
　　　　　　　　　　　　　　　　conn.close();
　　　　　　　　}
　　　　　　　　return　null;
　　　　}
　　　　public　Object　ExecuteScalar(String　cmdtext,　Parameters　parms)
　　　　　　　　　　　　throws　SQLException　{
　　　　　　　　PreparedStatement　pstmt　=　null;
　　　　　　　　ResultSet　rs　=　null;
　　　　　　　　try　{
　　　　　　　　　　　　pstmt　=　conn.prepareStatement(cmdtext);
　　　　　　　　　　　　prepareCommand(pstmt,　parms);
　　　　　　　　　　　　rs　=　pstmt.executeQuery();
　　　　　　　　　　　　if　(rs.next())　{
　　　　　　　　　　　　　　　　return　rs.getObject(1);
　　　　　　　　　　　　}　else　{
　　　　　　　　　　　　　　　　return　null;
　　　　　　　　　　　　}
　　　　　　　　}　catch　(Exception　e)　{
　　　　　　　　}　finally　{
　　　　　　　　　　　　if　(rs　!=　null)
　　　　　　　　　　　　　　　　rs.close();
　　　　　　　　　　　　if　(pstmt　!=　null)
　　　　　　　　　　　　　　　　pstmt.close();
　　　　　　　　　　　　if　(conn　!=　null)
　　　　　　　　　　　　　　　　conn.close();
　　　　　　　　}
　　　　　　　　return　null;
　　　　}
　　　　private　void　prepareCommand(PreparedStatement　pstmt,　Parameters　parms)
　　　　　　　　　　　　throws　SQLException　{
　　　　　　　　if　(parms　!=　null　&&　parms.getLength()　>　0)　{
　　　　　　　　　　　　for　(int　i　=　0;　i　<　parms.getLength();　i++)　{
　　　　　　　　　　　　　　　　MySqlParameter　parm　=　parms.getParameter(i);
　　　　　　　　　　　　　　　　String　value　=　parm.getValue().toString();
　　　　　　　　　　　　　　　　switch　(parm.getType())　{
　　　　　　　　　　　　　　　　case　String:
　　　　　　　　　　　　　　　　　　　　pstmt.setString(i　+　1,　value);
　　　　　　　　　　　　　　　　　　　　break;
　　　　　　　　　　　　　　　　case　Int16:
　　　　　　　　　　　　　　　　　　　　pstmt.setShort(i　+　1,　Short.parseShort(value));
　　　　　　　　　　　　　　　　　　　　break;
　　　　　　　　　　　　　　　　case　Int32:
　　　　　　　　　　　　　　　　　　　　pstmt.setInt(i　+　1,　Integer.parseInt(value));
　　　　　　　　　　　　　　　　　　　　break;
　　　　　　　　　　　　　　　　case　Int64:
　　　　　　　　　　　　　　　　　　　　pstmt.setLong(i　+　1,　Long.parseLong(value));
　　　　　　　　　　　　　　　　　　　　break;
　　　　　　　　　　　　　　　　case　DateTime:
　　　　　　　　　　　　　　　　　　　　pstmt.setDate(i　+　1,　Date.valueOf(value));
　　　　　　　　　　　　　　　　　　　　break;
　　　　　　　　　　　　　　　　default:
　　　　　　　　　　　　　　　　　　　　pstmt.setObject(i　+　1,　value);
　　　　　　　　　　　　　　　　　　　　break;
　　　　　　　　　　　　　　　　}
　　　　　　　　　　　　}
　　　　　　　　}
　　　　}
　　　　static　{
　　　　　　　　try　{
　　　　　　　　　　　　Class.forName("com.mysql.jdbc.Driver").newInstance();
　　　　　　　　}　catch　(Exception　ex)　{
　　　　　　　　}
　　　　}
　　　　public　Parameters　CreateFixedParms(int　size)　{
　　　　　　　　return　new　FixedParameters(size);
　　　　}
}