conn.java

学习资料学习资料学习资料学习资料学习资料

package com.java.dao;

import java.sql.*;

public class Conn {
	public Connection sqlconnection(){
		Connection conn=null;
		
			try {
				Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
			} catch (ClassNotFoundException e1) {
				System.out.println("驱动错误");
				e1.printStackTrace();
			}

		try {
			String url="jdbc:sqlserver://127.0.0.1:1433;databasename=web"; 
			String user="sa"; 
			String password="sa"; 
			conn=DriverManager.getConnection(url,user,password);
			System.out.println("连接成功");
		} catch (SQLException e) {
			System.out.println("连接错误");
			e.printStackTrace();
		}
		return conn;
	}

	public void closeConnection(Connection conn,PreparedStatement pt,ResultSet rs) {
		try {
			if(rs!=null){
				rs.close();
			}
			if(pt!=null){
				pt.close();
			}
			if(conn!=null&&(!conn.isClosed())){
			
				conn.close();
				conn=null;
			} 
			System.out.println("关闭成功");
		}
		catch (SQLException e) {
				System.out.println("关闭失败");
		}
	}
	public int executeSql(String sql,String[] param){
		Connection conn=null;
		PreparedStatement pstmt=null;
		int num=0;
		try {
			conn = sqlconnection();
			pstmt = conn.prepareStatement(sql);
			if (param != null) {
				for (int i = 0; i < param.length; i++) {
					pstmt.setString(i + 1, param[i]);
				}
			}
			num = pstmt.executeUpdate();
		} catch (Exception e) {
			e.printStackTrace();
		}
		finally{
			closeConnection(conn,pstmt,null);
		}
		return num;
	}

}