com.microsoft.sqlserver.jdbc.SQLServerException: Socket closed 或者 該連接已關閉

com.microsoft.sqlserver.jdbc.SQLServerException: Socket closed 或者 該連接已關閉

解決方案:

 

 DBUtil公共方法如下:

package com.dao;

import java.io.IOException;
import java.io.InputStream;
import java.sql.*;
import java.text.ParsePosition;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;
import java.util.Properties;

import com.fasterxml.jackson.core.JsonParseException;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.JsonMappingException;
import com.fasterxml.jackson.databind.ObjectMapper;

public class DBUtil {
    //連接對象
    //Statement 命令對象
    //打開連接
    //關閉連接
    //得到一個連接對象
    //查詢（有參，無參）
    //修改（有參，無參）
    static Statement stmt = null;
    //驅動，服務器地址，登錄用戶名，密碼    
    static String DBDRIVER;
    static String DBURL;
    static String DBUID;
    static String DBPWD;
    
    static {
        //先創建資源文件，擴展名為.properties
        //內容是以：dbuser=sa  格式
        
        Properties prop = new Properties();//先獲取資源對象
        //創建輸入流，讀取資源文件
        InputStream in =Thread.currentThread().getContextClassLoader()
                .getResourceAsStream("jdbc.properties");
        try {
            prop.load(in);//加載
            DBDRIVER = prop.getProperty("DBDRIVER");
            DBURL = prop.getProperty("DBURL");
            DBUID = prop.getProperty("DBUID");
            DBPWD = prop.getProperty("DBPWD");
            //System.out.println(DBDRIVER);
        } catch (IOException e) {
            System.out.println("資源文件讀取錯誤，請查看資源文件");
        } 
        try {
            in.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    //打開連接
     static  {
        //加載驅動
        try {
            Class.forName(DBDRIVER);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
    //關閉連接
    public static void close(Connection conn) {
        try {
            if(stmt!=null)
                    stmt.close();
            if(conn!=null && !conn.isClosed())
                conn.close();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    public static void close(ResultSet rs) {
        Statement st = null;
        Connection con = null;
        try {
            try {
                if (rs != null) {
                    st = rs.getStatement();
                    rs.close();
                }
            } finally {
                try {
                    if (st != null) {
                        con = st.getConnection();
                        st.close();
                    }
                } finally {
                    if (con != null) {
                        con.close();
                    }
                }
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    //得到一個連接對象，當用戶使用DBUtil無法解決個性問題時
    //可以通過本方法獲得連接對象
    public static Connection getConnection() {
         Connection conn = null;
        try {
            conn=DriverManager.getConnection(DBURL,DBUID,DBPWD);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return conn;
    }
    
    //executeQuery
    //executeUpdate
    //execute
    //獲得查詢的數據集
    //select * from student where name='' and sex=''
    public static ResultSet executeQuery(String sql) {
        Connection conn = getConnection();
        try {
            stmt = conn.createStatement();
            return stmt.executeQuery(sql);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return null;
    }
    
    //修改表格內容
    public static int executeUpdate(String sql) {
        Connection conn = getConnection();
        int result = 0;
        try {
            stmt = conn.createStatement();
            result = stmt.executeUpdate(sql);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            close(conn);
        }
        return result;
    }
    //如果執行的查詢或存儲過程，會返回多個數據集，或多個執行成功記錄數
    //可以調用本方法，返回的結果，
    //是一個List<ResultSet>或List<Integer>集合
    public static Object execute(String sql) {
        Connection conn = getConnection();
        boolean b=false;
        try {
            stmt = conn.createStatement();
            b = stmt.execute(sql);            
            //true,執行的是一個查詢語句，我們可以得到一個數據集
            //false,執行的是一個修改語句，我們可以得到一個執行成功的記錄數
            if(b){
                return stmt.getResultSet();
            }
            else {
                return stmt.getUpdateCount();
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            if(!b) {
                close(conn);
            }
        }
        return null;
    }
    
    //
    //select * from student where name=? and sex=?
    public static ResultSet executeQuery(String sql,Object[] in) {
        Connection conn = getConnection();
        try {
            PreparedStatement pst = conn.prepareStatement(sql);
            for(int i=0;i<in.length;i++)
                pst.setObject(i+1, in[i]);
            stmt = pst;//只是為了關閉命令對象pst
            return pst.executeQuery();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return null;
    }
    
    public static int executeUpdate(String sql,Object[] in) {
        Connection conn = getConnection();
        try {
            PreparedStatement pst = conn.prepareStatement(sql);
            for(int i=0;i<in.length;i++)
                pst.setObject(i+1, in[i]);
            stmt = pst;//只是為了關閉命令對象pst
            return pst.executeUpdate();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally {
            close(conn);
        }
        return 0;
    }
    public static Object execute(String sql,Object[] in) {
        Connection conn = getConnection();
        boolean b=false;
        try {
            PreparedStatement pst = conn.prepareStatement(sql);
            for(int i=0;i<in.length;i++)
                pst.setObject(i+1, in[i]);
            b = pst.execute();
            //true,執行的是一個查詢語句，我們可以得到一個數據集
            //false,執行的是一個修改語句，我們可以得到一個執行成功的記錄數
            if(b){
                System.out.println("----");
                /*List<ResultSet> list = new ArrayList<ResultSet>();
                list.add(pst.getResultSet());
                while(pst.getMoreResults()) {
                    list.add(pst.getResultSet());
                }*/
                return pst.getResultSet();
            }
            else {
                System.out.println("****");
                List<Integer> list = new ArrayList<Integer>();
                list.add(pst.getUpdateCount());
                while(pst.getMoreResults()) {
                    list.add(pst.getUpdateCount());
                }
                return list;
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            if(!b) {
                System.out.println("====");
                close(conn);
            }
        }
        return null;
    }
    //調用存儲過程  proc_Insert(?,?,?)
    public static Object executeProcedure(String procName,Object[] in) {
        Connection conn = getConnection();
        try {
            procName = "{call "+procName+"(";
            String link="";
            for(int i=0;i<in.length;i++) {
                procName+=link+"?";
                link=",";
            }
            procName+=")}";
            CallableStatement cstmt = conn.prepareCall(procName);
            for(int i=0;i<in.length;i++) {
                cstmt.setObject(i+1, in[i]);
            }
            if(cstmt.execute())
            {
                return cstmt.getResultSet();
            }
            else {
                return cstmt.getUpdateCount();
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        return null;
    }
    

    /*
     * 調用存儲過程，並有輸出參數
     * @procName ，存儲過程名稱：proc_Insert(?,?)
     * @in ,輸入參數集合
     * @output,輸出參數集合
     * @type,輸出參數類型集合
     * */
    public static Object executeOutputProcedure(String procName,
            Object[] in,Object[] output,int[] type){
        Connection conn = getConnection();
        Object result = null;
        try {
            CallableStatement cstmt = conn.prepareCall("{call "+procName+"}");
            //設置存儲過程的參數值
            int i=0;
            for(;i<in.length;i++){//設置輸入參數
                cstmt.setObject(i+1, in[i]);
                //print(i+1);
            }
            int len = output.length+i;
            for(;i<len;i++){//設置輸出參數
                cstmt.registerOutParameter(i+1,type[i-in.length]);
                //print(i+1);
            }
            boolean b = cstmt.execute();
            //獲取輸出參數的值
            for(i=in.length;i<output.length+in.length;i++)
                output[i-in.length] = cstmt.getObject(i+1);
            if(b) {
                result = cstmt.getResultSet();
            }
            else {
                result = cstmt.getUpdateCount();
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return result;
    }
    public static String toJson(Object obj){
        String reuqest=null;
        //對象映射
        ObjectMapper mapper=new ObjectMapper();
        //設置時間格式
        SimpleDateFormat dateFormat=new SimpleDateFormat("yyyy年MM月dd日");
        mapper.setDateFormat(dateFormat);
            try {
                reuqest=mapper.writeValueAsString(obj);
            } catch (JsonProcessingException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        return reuqest;
    }
    public static <T> T toObject(String src,Class<T> valueType){
        T request=null;
            //對象反射
          ObjectMapper mapper=new ObjectMapper();
          try {
            request=mapper.readValue(src, valueType);
        } catch (JsonParseException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (JsonMappingException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return request;
    }
    public static Date date(String date_str) {
        try {
            Calendar zcal = Calendar.getInstance();//日期類
            Timestamp timestampnow = new Timestamp(zcal.getTimeInMillis());//轉換成正常的日期格式
            SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");//改為需要的東西
            ParsePosition pos = new ParsePosition(0);
            java.util.Date current = formatter.parse(date_str, pos);
            timestampnow = new Timestamp(current.getTime());
            return timestampnow;
        }
        catch (NullPointerException e) {
            return null;
        }
    }
}

　　聲明：使用該公共方法需要在WEB-INF/classes/jdbc.properties添加連接驅動等等 如圖:

 

在classes中加入鏈接

 

DBDRIVER=com.microsoft.sqlserver.jdbc.SQLServerDriver
DBURL=jdbc:sqlserver://localhost:1433;databasename=AJAX_ProductDB
DBUID=sa
DBPWD=123456