jdbc

數據庫鏈接類

package sqlServer;
import java.sql.Connection;
import java.sql.DriverManager;
/**
 * 數據庫鏈接類
 * 
 * @author Administrator
 * 
 */
public class DBConnection {
 // 加載並鏈接本地的SQLServer
 String driverName = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
 String dbURL = "jdbc:sqlserver://1.1.2.2:1433;DatabaseName=testImage;"; // "USCSecondhandMarketDB"是數據庫名稱
 String userName = "test"; // 用戶名
 String pwd = "456"; // 密碼
 /**
  * 建立時加載驅動
  */
 public DBConnection() {
  try {
   Class.forName(driverName);
  } catch (Exception e) {
   System.err.println("驅動加載失敗");
  }
 }
 public Connection getConnection() {
  Connection con = null;
  try {
   con = DriverManager.getConnection(dbURL, userName, pwd);
   System.err.println("數據庫鏈接成功");
  } catch (Exception e) {
   e.printStackTrace();
  }
  return con;
 }
}

對數據的操做

package sqlServer;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import entity.Entity;
/**
 * 對數據的操做
 */
public class Dao {
 DBConnection dbCon = null;
 Connection connection = null;
 PreparedStatement state = null;// 預編譯的sql語句對象
 String sql = null;// sql語句
 /**
  * 建立用戶操做類時加載驅動
  */
 public Dao() {
  dbCon = new DBConnection();
 }
 /** 
     * 批量添加到sqlserver
     */  
    public void add(ArrayList<Entity> list){
        connection=dbCon.getConnection();  
        sql="insert into image values(?,?)"; 
        try{
         connection.setAutoCommit(false);
            state=connection.prepareStatement(sql);
            for(int i = 0;i<list.size();i++){
                state.setString(1, list.get(i).getId());  
                state.setString(2, list.get(i).getImage()); 
             state.addBatch();
            }
            state.executeBatch();
            connection.commit();
            System.err.println("數據批量插入sqlserver成功");
            state.close();  
        }catch(Exception e){
         System.err.println("數據插入sqlserver失敗");
            e.printStackTrace();
        }finally{
            if(connection!=null){
                try{  
                    connection.close();
                }catch(Exception e){
                    e.printStackTrace();  
                }  
            }  
        }  
    }
    
    /** 
     * 根據ID查找圖片
     * @param ID 
     */  
    public Entity getImageList(String id){
     Entity entity = new Entity();
        connection=dbCon.getConnection();  
        sql="select * from image where id=?";
        try{
            state=connection.prepareStatement(sql);
            state.setString(1, id);
            ResultSet set=state.executeQuery();
            while(set.next()){
             entity.id = set.getString("id").trim();
                entity.image = set.getString("image").trim();
            }  
            state.close();  
            set.close(); 
            System.err.println("從sqlserver中查找成功");
        }catch(Exception e){
         System.err.println("從sqlserver中查找失敗");
        }finally{
            if(connection!=null){
                try{
                    connection.close();  
                }catch(Exception e){
                    e.printStackTrace();  
                }  
            }  
        }  
        return entity;  
    }  
}