手把手封装数据层之DButil数据库连接的封装

//DButil.java

package com.yck.database;

import java.io.IOException;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;

public class DButil
{
    private static String username;
    private static String password;
    private static String url;
    private static String driver;
    static
    {
        getDatabaseInfo("jdbc.properties");
        try
        {
            Class.forName(driver);
        } catch (ClassNotFoundException e)
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    
    public static void getDatabaseInfo(String path)
    {
        InputStream in = DButil.class.getClassLoader().getResourceAsStream(path);
        Properties p = new Properties();
        try
        {
            p.load(in);
            username = p.getProperty("jdbc.username");
            password = p.getProperty("jdbc.password");
            url = p.getProperty("jdbc.url");
            driver = p.getProperty("jdbc.driver");
        } catch (IOException e)
        {
            e.printStackTrace();
        }
    }
    
    
    public static Connection getConnection()
    {
        Connection conn = null;
        try
        {
            conn = DriverManager.getConnection(url,username,password);
        }catch (SQLException e)
        {
            e.printStackTrace();
        }
        return conn;
    }
    public static void closeConnection(Connection connection)
    {
        try
        {
            if(connection != null)
            {
                connection.close();
                connection = null;
            }
        }  catch (SQLException e)
        {
            e.printStackTrace();
        }
    }
    
    public static PreparedStatement prepareStatement(Connection connection,String sql)
    {
        PreparedStatement preparedStatement = null;
        try
        {    
            preparedStatement = connection.prepareStatement(sql);
        } catch (SQLException e)
        {
            e.printStackTrace();
        }
        return preparedStatement;
    }
    public static void closePreparedStatement(PreparedStatement preparedStatement)
    {
        try
        {
            if(preparedStatement != null)
            {
                preparedStatement.close();
                preparedStatement = null;
            }
        }  catch (SQLException e)
        {
            e.printStackTrace();
        }
    }
    
    public static Statement createStatement(Connection connection)
    {
        Statement statement = null;
        try
        {    
            statement = connection.createStatement();
        } catch (SQLException e)
        {
            e.printStackTrace();
        }
        return statement;
    }
    public static void closeStatement(Statement statement)
    {
        try
        {
            if(statement != null)
            {
                statement.close();
                statement = null;
            }
        }  catch (SQLException e)
        {
            e.printStackTrace();
        }
    }
    public static ResultSet getResultSet(Statement statement,String sql)
    {
        ResultSet resultSet = null;
        try
        {    
            resultSet = statement.executeQuery(sql);
        } catch (SQLException e)
        {
            e.printStackTrace();
        }
        return resultSet;
    }
    public static void closeResultSet(ResultSet resultSet)
    {
        try
        {
            if(resultSet != null)
            {
                resultSet.close();
                resultSet = null;
            }
        }  catch (SQLException e)
        {
            e.printStackTrace();
        }
    }

}

jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8&useSSL=true
jdbc.username=root
jdbc.password=8888888

CREATE DATABASE test;
USE test;

CREATE TABLE t_user
(
id INT AUTO_INCREMENT NOT NULL,
name VARCHAR(20),
age INT,
PRIMARY KEY(id)
)ENGINE=InnoDB DEFAULT CHARSET=utf8

package com.yck.database;

import java.sql.*;

public class Test
{

    public static void main(String[] args)
    {
        Connection conn = DButil.getConnection();
        Statement stam =DButil.createStatement(conn);
        String sql = "select * from t_user";
        ResultSet rs = null;
        try
        {
            rs = stam.executeQuery(sql);
            while(rs.next())
            {
                System.out.println(rs.getString("name"));
            }
            
        } catch (SQLException e)
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        DButil.closeResultSet(rs);
        DButil.closeStatement(stam);
        DButil.closeResultSet(rs);
    }

}