axis2之webservice新手超详细教程(7)

* @throws Exception SqlException异常 */

static synchronized public Connection getConnection() throws Exception {

String dbSystem=null;

Connection aConnection;

ResourceBundle db = ResourceBundle.getBundle(\); //读取配置文件

dbSystem=db.getString(propertiesFileName);

ResourceBundle rb = ResourceBundle.getBundle(dbSystem); //读取配置文件

Class.forName(rb.getString(\)).newInstance();

aConnection =

DriverManager.getConnection(rb.getString(\),rb.getString(\database.username\),rb.getString(\)); //创建aConnection对象

aConnection.setAutoCommit(false); //设置不自动提交事务

return aConnection; //返回aConnection对象 }

/** 当前使用的数据库系统名称 *

* @param echoable 如果启用回显将在控制台输出描述当前数据库系统的信息

* @return dbSystem 数据库系统名称 */

public static String getCurrentDBMS(boolean echoable) { String dbSystem=null;

ResourceBundle rb = ResourceBundle.getBundle(\); //读取配置文件

dbSystem=rb.getString(propertiesFileName);

if (echoable)System.out.println(\are \+dbSystem); return dbSystem; } }

(二) IOperationCore.java（数据库操作接口)

/**

* 数据库常用操作封装 */

package database;

import java.sql.ResultSet; import java.sql.SQLException; import java.util.Collection;

/** 类名：IOperationCore
*

* 作用: 该接口封装了数据库操作的大部分方法
*

* 创建人：陶尚明
*/

public interface IOperationCore { /** sql更新语句 *

* @param queryString 查询语句

* @return 返回一个ResultSet结果集

*

* @exception SQLException */

ResultSet executeQuery(String queryString) throws SQLException; /**

* sql更新语句 *

* @param updateString 数据库更新语句 * @return 更新数据库影响行数 *

* @exception SQLException */

int executeUpdate(String updateString) throws SQLException; /**

* 读取行个数 *

* @param queryString 查询语句

* @return Transact-SQL 查询后的虚拟表的行数 *

* @exception SQLException */

int getRowCount(String queryString) throws SQLException; /**

* 读取列数个数 *

* @param queryString 查询语句

* @return Transact-SQL 查询后的虚拟表的列数 *

* @exception SQLException */

int getColumnCount(String queryString) throws SQLException; /** * 读取列名 *

* @param columIndex 列索引

* @param queryString 提供ResultSet二维表的查询字符串 * @return ResultSet表中的指定的列名 *

* @exception SQLException */

String getColumnName(int columIndex, String queryString) throws SQLException; /**

* 读取queryString查询结果集ResultSet表中的所有列名 *

* @param queryString 用于返回ResultSet结果集的语句

* @return 表中的所有列名