數據庫的封裝，並利用javabean來存儲取得內容

package com.zhao.practice726;
/**
 * javaBean
 * @author Administrator
 *
 */
public class Person {
 private int id;
 private String name;
 public int getId() {
  return id;
 }
 public void setId(int id) {
  this.id = id;
 }
 public String getName() {
  return name;
 }
 public void setName(String name) {
  this.name = name;
 }
 @Override
 public String toString() {
  return id+"  "+name;
 }
 
}

 

 

 

package com.zhao.practice726;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

public class TestDBHelper {
 private static List<Person> list = null;

 /**
  * @param args
  */
 public static void main(String[] args) {
  String sql = "select id ,name from test1";
  TestDBHelper test = new TestDBHelper();
  list = test.meth0d2(sql);
  
  //for加強
  for(Person person : list){
   System.out.println(person.getName());
  }
  
 }
 
 /**
  * 利用集合來封裝
  */
 private List<Person> meth0d2(String sql){
  list = new ArrayList<Person>();
  Person person = null;
  DBHelper db = new DBHelper();
  ResultSet rs = db.getDataByQuery(sql);
  try{
   while(rs.next()){
    person = new Person();
    person.setId(rs.getInt("id"));
    person.setName(rs.getString("name"));
    
    list.add(person);
   }
   return list;
  }catch(SQLException e){
   e.printStackTrace();
  }
  return null;
 }
 
 
 /**
  * 簡單測試
  */
 private void method1(String sql) {
  

  DBHelper db = new DBHelper();
  ResultSet rs = db.getDataByQuery(sql);
  try {
   while (rs.next()) {
    System.out.println(rs.getString(1) + "  " + rs.getString(2));
   }
  } catch (SQLException e) {
   e.printStackTrace();
  }
  db.close();
 }

}

 

 

package com.zhao.practice726;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DBHelper {
 /**
  * 加載類字符串
  */
 private static final String DRIVER = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
 /**
  * url字符串
  */
 private static final String URL = "jdbc:sqlserver://localhost:1433; DatabaseName=zhao722";
 /**
  * 用戶名字符串
  */
 private static final String USER = "sa";
 /**
  * 登錄密碼字符串
  */
 private static final String PASSWORD = "zhao";
 /**
  * 鏈接數據庫
  */
 Connection conn = null;

 /**
  * 獲取Statement
  */
 Statement stat = null;

 /**
  * 獲取結果集
  */
 ResultSet rs = null;

 static {
  try {
   Class.forName(DRIVER);
  } catch (Exception e) {
   e.printStackTrace();
  }
 }

 /**
  * 獲取數據庫鏈接
  */
 private Connection getConnection() {

  try {
   conn = DriverManager.getConnection(URL, USER, PASSWORD);
   return conn;
  } catch (SQLException e) {

   e.printStackTrace();
  }
  return null;
 }

 /**
  * 得到Statement
  */
 private Statement getStatement() {

  try {
   stat = getConnection().createStatement();
   return stat;
  } catch (SQLException e) {
   e.printStackTrace();
  }
  return null;
 }

 /**
  * 獲取ResultSet
  *
  * @param sql
  *            sql語句
  * @return 查詢到的ResultSet
  */
 public ResultSet getDataByQuery(String sql) {

  try {
   rs = getStatement().executeQuery(sql);
   return rs;
  } catch (SQLException e) {
   e.printStackTrace();
  }
  return null;
 }

 /**
  * 對數據庫進行增刪改查
  *
  * @param sql
  *            sql語句
  * @return int
  */
 public int operatorLineByQuery(String sql) {
  try {
   int line = getStatement().executeUpdate(sql);
   return line;
  } catch (SQLException e) {
   e.printStackTrace();
  }
  return 0;
 }

 /**
  * 關閉全部在數據庫上的鏈接
  */
 public void close() {
  try {
   if (rs != null){
    rs.close();
   }
   if(stat != null){
    stat.close();
   }
   if(conn != null){
    conn.close();
   }
  } catch (SQLException e) {
   e.printStackTrace();
  }

 } }