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

* @return 返回一个ResultSet结果集 *

* @exception SQLException */

public ResultSet executeQuery(String queryString) {

try {

aStatement = aConnection.createStatement(); aResultSet = aStatement.executeQuery(queryString);

} catch (SQLException e) { }

aResultSet=null; e.printStackTrace();

return aResultSet; } /**

* sql更新语句 *

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

* @exception SQLException */

public int executeUpdate(String updateString) {

int effectedRows=0; try{

aConnection.setAutoCommit(false);

aStatement = aConnection.createStatement(); effectedRows =

aStatement.executeUpdate(updateString); }

aConnection.commit();

}catch(SQLException ex){ }

return effectedRows;

System.out.println(\数据库写操作失败!\if(aConnection!=null) { }

try {

aConnection.rollback();

System.out.println(\事务回滚成功\

} catch (SQLException e) { }

System.out.println(\事务回滚失败\e.printStackTrace();

/**

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

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

* @return 表中的所有列名 * @throws SQLException */

public Collection getColumnNames(String queryString) {

ArrayList ColumnNames=new ArrayList(); try {

aResultSet=executeQuery(queryString);

ResultSetMetaData rsmd=aResultSet.getMetaData(); int j=rsmd.getColumnCount(); for(int k=0;k

ColumnNames.add(rsmd.getColumnName(k+1));

} catch (SQLException e) {

ColumnNames=null; e.printStackTrace();

}

return ColumnNames; } /**

* 读取queryString查询结果集ResultSet表中的所有字段类型名称 *

* @param queryString 用于返回查询结果集的语句 * @return 表中的所有字段类型名称 * @throws SQLException */

public Collection getColumnTypeNames(String queryString) {

ArrayList ColumnNames=new ArrayList(); try {

aResultSet=executeQuery(queryString);

ResultSetMetaData rsmd=aResultSet.getMetaData(); int j=rsmd.getColumnCount(); for(int k=0;k

ColumnNames.add(rsmd.getColumnTypeName(k+1));

}

} /**

} catch (SQLException e) { }

return ColumnNames;

ColumnNames=null; e.printStackTrace();

* 读取列名 *

* @param columIndex 列索引

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

* @exception SQLException */

public String getColumnName(int columIndex, String queryString)

{

String columnName=null; try {

aResultSet=executeQuery(queryString); rsmd=aResultSet.getMetaData();

columnName=rsmd.getColumnName(columIndex + 1);