getdbdata.java~8~

用户登录

package myapp;

import java.util.*;
import java.sql.*;
import java.io.*;
import java.lang.*;
import javax.sql.*;
import javax.naming.*;

/**
 * <p>获取数据类</p>
 */
public class GetDBData {
  Connection con = null;
  Statement stmt = null;
  PreparedStatement pstm = null;
  ResultSet rs = null;
  public GetDBData() {
  }

  //获取数据
  public Vector getData(String sql) {
    Vector vect = new Vector();
    try {
      DBConnection dbConnection = new DBConnection();
      dbConnection.getConnection();
      rs = dbConnection.selectRecord(sql);
      ResultSetMetaData rsmd = rs.getMetaData();
      int cols = rsmd.getColumnCount();
      while (rs.next()) {
        Hashtable hash = new Hashtable();
        for (int i = 1; i <= cols; i++) {
          String field = rsmd.getColumnName(i);
          String value = rs.getString(i);
          hash.put(field, value);
        }
        vect.add(hash);
      }
    }
    catch (SQLException e) {
      System.out.println("查询数据时出错！错误为：" + e);
    }
    finally {
      closeConnect();
    }
    return vect;
  }

  //获取数据集
  public Vector getResultSetData(ResultSet rs) {
    Vector vect = new Vector();
    try {
      //获取列名和列数
      ResultSetMetaData rsmd = rs.getMetaData();
      int cols = rsmd.getColumnCount();
      while (rs.next()) {
        Hashtable hash = new Hashtable();
        for (int i = 1; i <= cols; i++) {
          //FormatString ds = new FormatString();
          String field = rsmd.getColumnName(i);
          String value = rs.getString(i);
          hash.put(field, value);
        }
        vect.add(hash);
      }
    }
    catch (SQLException e) {
      System.out.println("查询数据集时出错！错误为：" + e);
    }
    return vect;
  }

}