package com.xk.demotest.tools;

import java.io.IOException;

import java.io.InputStream;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Properties;

public class DaoDBConectTools {

    /*

    // 传统jdbc连接

    private static final String driverName = "com.mysql.jdbc.Driver";

    private static final String url = "jdbc:mysql://localhost:3306/20170626javaweb01";

    private static final String user = "root";

    private static final String password = "root";

    public DaoDBConectTools() {

        Connection connect = null;

        Statement state = null;

        try {

            Class.forName(driverName);

            connect = DriverManager.getConnection(url, user, password);

            state = connect.createStatement();

            String sql = "";

            state.executeQuery(sql);

        } catch (ClassNotFoundException | SQLException e) {

            e.printStackTrace();

        } finally {

            try {

                state.close();

                connect.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

    }

*/

    private static final Properties pro = new Properties(); // ①创建properties对象

    //加载配置文件和驱动

    static {

        InputStream iStream = Thread.currentThread().getContextClassLoader().getResourceAsStream("config.properties"); // ②引入配置文件

        try {

            pro.load(iStream); // ②引入配置文件

            String driverName = pro.getProperty("driverName"); // ③加载驱动

            Class.forName(driverName);

        } catch (IOException | ClassNotFoundException e) {

            e.printStackTrace();

        }

    }

    //获取连接对像并创建连接

    public static Connection connection() {

        String url = pro.getProperty("url");

        String user = pro.getProperty("userName");

        String password = pro.getProperty("password");

        Connection connect = null;

        try {

            connect = DriverManager.getConnection(url, user, password);

        } catch (SQLException e) {

            e.printStackTrace();

        }

        return connect;

    }

    //关闭数据库连接

    public static void close(Connection connect, Statement state) {

        if (state != null) {

            try {

                state.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

        if (connect != null) {

            try {

                connect.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

    }

}