[java]代码库package com.mwq.dao;

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.ResultSetMetaData;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Vector;

public class BaseDao {

// 查询多个记录

protected Vector selectSomeNote(String sql) {

Vector> vector = new Vector>();// 创建结果集向量

Connection conn = JDBC.getConnection();// 获得数据库连接

try {

Statement stmt = conn.createStatement();// 创建连接状态对象

ResultSet rs = stmt.executeQuery(sql);// 执行SQL语句获得查询结果

int columnCount = rs.getMetaData().getColumnCount();// 获得查询数据表的列数

int row = 1;// 定义行序号

while (rs.next()) {// 遍历结果集

Vector rowV = new Vector();// 创建行向量

rowV.add(new Integer(row++));// 添加行序号

for (int column = 1; column <= columnCount; column++) {

rowV.add(rs.getObject(column));// 添加列值

}

vector.add(rowV);// 将行向量添加到结果集向量中

}

rs.close();// 关闭结果集对象

stmt.close();// 关闭连接状态对象

} catch (SQLException e) {

e.printStackTrace();

}

return vector;// 返回结果集向量

}

// 查询单个记录

protected Vector selectOnlyNote(String sql) {

Vector vector = null; //结果集向量为空

Connection conn = JDBC.getConnection(); // 获得数据库连接

try {

Statement stmt = conn.createStatement(); // 创建连接状态对象

ResultSet rs = stmt.executeQuery(sql); // 执行SQL语句获得查询结果

int columnCount = rs.getMetaData().getColumnCount(); // 获得查询数据表的列数

while (rs.next()) { // 遍历结果集

vector = new Vector(); //创建向量

for (int column = 1; column <= columnCount; column++) {

vector.add(rs.getObject(column)); //添加向量值

}

}

rs.close(); // 关闭结果集对象

stmt.close(); // 关闭连接状态对象

} catch (SQLException e) {

e.printStackTrace();

}

return vector; // 返回结果集向量

}

// 查询多个值

protected Vector selectSomeValue(String sql) {

Vector vector = new Vector(); //创建结果集向量

Connection conn = JDBC.getConnection(); // 获得数据库连接

try {

Statement stmt = conn.createStatement(); // 创建连接状态对象

ResultSet rs = stmt.executeQuery(sql); // 执行SQL语句获得查询结果

while (rs.next()) { // 遍历结果集

vector.add(rs.getObject(1)); //添加结果集向量

}

rs.close(); // 关闭结果集对象

stmt.close(); // 关闭连接状态对象

} catch (SQLException e) {

e.printStackTrace();

}

return vector; // 返回结果集向量

}

// 查询单个值

protected Object selectOnlyValue(String sql) {

Object value = null; //值为空

Connection conn = JDBC.getConnection(); //获得数据库连接

try {

Statement stmt = conn.createStatement(); //创建数据状态连接对象

ResultSet rs = stmt.executeQuery(sql); //执行SQL语句获得查询结果

while (rs.next()) {

value = rs.getObject(1);

}

rs.close(); //关闭结果集对象

stmt.close(); //关闭连接状态对象

} catch (SQLException e) {

e.printStackTrace();

}

return value; //返回单个值

}

// 插入、修改、删除记录

public boolean longHaul(String sql) {

boolean isLongHaul = true;// 默认持久化成功

Connection conn = JDBC.getConnection();// 获得数据库连接

try {

conn.setAutoCommit(false);// 设置为手动提交

Statement stmt = conn.createStatement();// 创建连接状态对象

stmt.executeUpdate(sql);// 执行SQL语句

stmt.close();// 关闭连接状态对象

conn.commit();// 提交持久化

} catch (SQLException e) {

isLongHaul = false;// 持久化失败

try {

conn.rollback();// 回滚

} catch (SQLException e1) {

e1.printStackTrace();

}

e.printStackTrace();

}

return isLongHaul;// 返回持久化结果

}

public static void main(String[] args) {

BaseDao d=new BaseDao();

d.longHaul("delete from tb_order_item");

d.longHaul("delete from tb_order_form");

d.longHaul("delete from tb_user");

}

}