尚硅谷大数据技术之电信客服

11. 创建类：JDBCUtil
    package com.atguigu.utils;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.sql.*;

public class JDBCUtil {
private static final Logger logger = LoggerFactory.getLogger(JDBCUtil.class);
private static final String MYSQL_DRIVER_CLASS = "com.mysql.jdbc.Driver";
private static final String MYSQL_URL = "jdbc:mysql://linux01:3306/db_telecom?useUnicode=true&characterEncoding=UTF-8";
private static final String MYSQL_USERNAME = "root";
private static final String MYSQL_PASSWORD = "000000";
/**
* 获取Mysql数据库的连接
* @return
*/
public static Connection getConnection() throws SQLException {
try {
Class.forName(MYSQL_DRIVER_CLASS);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
return DriverManager.getConnection(MYSQL_URL, MYSQL_USERNAME, MYSQL_PASSWORD);
}

/**
 * 关闭数据库连接释放资源
 * @param connection
 * @param statement
 * @param resultSet
 */
public static void close(Connection connection, Statement statement, ResultSet resultSet){
    if(resultSet != null) try {
        resultSet.close();
    } catch (SQLException e) {
    }

    if(statement != null) try {
        statement.close();
    } catch (SQLException e) {
        e.printStackTrace();
    }

    if(connection != null) try {
        connection.close();
    } catch (SQLException e) {
        e.printStackTrace();
    }
}

}

12. 创建类：JDBCCacheBean
    package com.atguigu.utils;

import java.sql.Connection;
import java.sql.SQLException;

public class JDBCCacheBean {
private static Connection conn = null;
private JDBCCacheBean(){}
public static Connection getInstance(){
try {
if(conn == null || conn.isClosed() || conn.isValid(3)){
conn = JDBCUtil.getConnection();
}
} catch (SQLException e) {
e.printStackTrace();
}
return conn;
}
}

13. 创建类：IConverter
    package com.atguigu.analysis.converter;

import com.atguigu.analysis.kv.base.BaseDimension;

import java.io.Closeable;
import java.io.IOException;

public interface IConverter {
// 根据传入的dimension对象，获取数据库中对应该对象数据的id，如果不存在，则插入该数据再返回
int getDimensionId(BaseDimension dimension) throws IOException;
}

本教程由尚硅谷教育大数据研究院出品，如需转载请注明来源，欢迎大家关注尚硅谷公众号（atguigu）了解更多。