package com.example.ua.utils;

import com.example.ua.config.ApplicationConfig;

import org.mariadb.jdbc.MariaDbDataSource;
import org.mariadb.jdbc.MariaDbStatement;
//import org.slf4j.Logger;
import org.apache.log4j.Logger;
import org.slf4j.LoggerFactory;

import org.mariadb.jdbc.MariaDbConnection;
import java.sql.SQLException;

/**
 * 建立连接
 */
public class MariaDBConnect{
    private static final Logger LOG = Logger.getLogger(MariaDBConnect.class);

    public static MariaDbStatement getMariaDB(){
        String addr = "jdbc:mariadb://"
                + ApplicationConfig.MARIADB_HOST + ":"
                + ApplicationConfig.MARIADB_PORT + "/"
                + ApplicationConfig.MARIADB_DB_NAME;

        MariaDbDataSource dataSource = new MariaDbDataSource(addr);
        MariaDbStatement statement = null;

        try {
            MariaDbConnection conn = (MariaDbConnection) dataSource.getConnection(
                    ApplicationConfig.MARIADB_USER,
                    ApplicationConfig.MARIADB_PASSWORD);
            statement = (MariaDbStatement) conn.createStatement();
        } catch (SQLException e) {
            LOG.error("GetMariaDBConnection Faild. " + e.toString());
        }
        return statement;
    }

}