如何封装JDBC

以你之姓@ 2022-03-18 06:28 198阅读 0赞

# 如何封装JDBC #

--------------------

前言：封装JDBC需要用到properties类的知识，如果不懂这块知识的可以查阅我之前写的blog。

--------------------

## 首先简单看一眼执行步骤： ##

1.  创建properties文件
2.  创建工具类DBUtil
3.  定义对象：`static Properties properties`（**static方法随类产生，最先加载且只加载一次**）并且创建方法

InputStream is=Thread.currentThread().getContextClassLoader().getResourceAsStream("db.properties");
    Properties  properties = new Properties();
    properties.load(is);
    return properties;

1.  封装**连接**方法：`public static Connection getConn()`

Properties property = getDBInfo();
    String url=properties.getProperty("url");
    ......
    return conn;

1.  封装**关闭**方法

--------------------

## 具体步骤： ##

### 首先我们写一个properties文件，用于保存配置信息。 ###

DRIVER:com.mysql.jdbc.Driver
    URL:jdbc:mysql://localhost:3306/db214
    USER:root
    PASSWORD:123456

--------------------

### 然后创建`properties`对象并且创建方法： ###

public class DBUtil { 
    	static Properties properties;
    	//配置文件信息
    	public static Properties getDBInfo(){ 
    		InputStream is=Thread.currentThread().getContextClassLoader().getResourceAsStream("db.properties");
    		properties = new Properties();
    		try { 
    			properties.load(is);
    		} catch (IOException e) { 
    			e.printStackTrace();
    		}
    		return properties;
    	}

--------------------

### 封装连接方法：`public static Connection getConn()` ###

public Connection getCon(){ 
    		Properties property = getDBInfo();
    		String driver=property.getProperty("DRIVER");
    		String url=property.getProperty("URL");
    		String user=property.getProperty("USER");
    		String password=property.getProperty("PASSWORD");
    		Connection conn=null;
    		try { 
    			Class.forName(driver);
    			conn = DriverManager.getConnection(url, user, password);
    		} catch (ClassNotFoundException | SQLException e) { 
    			e.printStackTrace();
    		}
    		return conn;
    	}

--------------------

### 用PreparedStatement来实现动态获取： ###

public PreparedStatement getPs(){ 
    		Connection con = getCon();
    		PreparedStatement ps=null;
    		try { 
    			String sql="update emp set sal=2000 where empno=?";
    			ps = con.prepareStatement(sql);
    		} catch (SQLException e) { 
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    		return ps;
    	}

--------------------

### 封装关闭方法： ###

public void closeSource(ResultSet rs,PreparedStatement ps,Connection conn){ 
    		if (rs!=null) { 
    			try { 
    				rs.close();
    			} catch (SQLException e) { 
    				// TODO Auto-generated catch block
    				e.printStackTrace();
    			}
    		}
    		if (ps!=null) { 
    			try { 
    				ps.close();
    			} catch (SQLException e) { 
    				e.printStackTrace();
    			}
    		}
    		if (conn!=null) { 
    			try { 
    				conn.close();
    			} catch (SQLException e) { 
    				// TODO Auto-generated catch block
    				e.printStackTrace();
    			}
    		}
    	}
    }

--------------------

### 主函数： ###

public class Test { 
    	public static void main(String[] args) { 
    		DBUtil du=new DBUtil();
    		PreparedStatement ps = du.getPs();
    		try { 
    			ps.setString(1,"10004");
    			int i = ps.executeUpdate();
    			System.out.println("成功操作了："+i+"条数据！");
    		} catch (SQLException e) { 
    			e.printStackTrace();
    		}
    	}
    }