(java 功能篇) Java MySQL数据库连接工具类

朱雀 2023-10-16 20:21 11阅读 0赞

package com.vixuan.database;
    
    import java.io.IOException;
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    import java.util.HashMap;
    import java.util.Map;
    import java.util.Properties;
    
    
    public class MySQLUtil {
    	public Map getURL() {
    		// 读取配置文件类
    		Properties p = new Properties();
    		try {
    			// Java反射机制--加载Oracle数据库配置文件
    			p.load(getClass().getClassLoader().getResourceAsStream(
    					"jdbc.properties"));
    		} catch (IOException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    		String url = p.getProperty("url");
    		String username = p.getProperty("username");
    		String pwd = p.getProperty("password");
    		Map map = new HashMap();
    		map.put("url", url);
    		map.put("uname", username);
    		map.put("pwd", pwd);
    		return map;
    	}
    
    	public static Connection getConn() {
    		MySQLUtil jdbc = new MySQLUtil();
    		Map cmap = jdbc.getURL();
    		String url = (String) cmap.get("url");
    		String user = (String) cmap.get("uname");
    		String password = (String) cmap.get("pwd");
    		// Oracle 数据库连接类
    		Connection conn = null;
    		try {
    			// 加载oracle 数据库驱动
    			Class.forName("com.mysql.jdbc.Driver").newInstance();
    			conn = DriverManager.getConnection(url, user, password);
    			System.out.println("Mysql数据库连接成功！");
    		} catch (InstantiationException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		} catch (IllegalAccessException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		} catch (ClassNotFoundException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		} catch (SQLException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    		return conn;
    
    	}
    
    	// 关闭Oracle 数据库连接方法一
    	public static void closeCSR(Connection conn, Statement st, ResultSet rs) {
    		try {
    			if (rs != null)
    				rs.close();
    			if (st != null)
    				st.close();
    			if (conn != null) {
    				conn.close();
    			}
    		} catch (Exception e) {
    			// TODO: handle exception
    			e.printStackTrace();
    		}
    
    	}
    
    	// 关闭oracle 数据库连接方法二
    	public static void closeCS(Connection conn, Statement st) {
    		try {
    			if (st != null) {
    				st.close();
    			}
    			if (conn != null) {
    				conn.close();
    			}
    		} catch (SQLException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    
    	}
    
    	// OracleUtil数据库工具类测试方法
    	public static void main(String[] args) {
    		MySQLUtil util = new MySQLUtil();
    		util.getConn();
    	}
    
    }

jdbc.properties

url=jdbc:mysql://127.0.0.1:3306/location
    username=root
    password=123456