package com.example.ua.utils;

import com.example.ua.config.ApplicationConfig;

import org.mariadb.jdbc.MariaDbDataSource;
import org.mariadb.jdbc.MariaDbStatement;
import org.apache.log4j.Logger;

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

/**
 * 建立连接
 * @author yjy
 * @version 1.0
 * @date 2020/11/15 12:20 下午
 */
public class MariaDBConnect{
    private static final Logger LOG = Logger.getLogger(MariaDBConnect.class);

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

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

        MariaDbConnection conn = (MariaDbConnection) dataSource.getConnection(
                ApplicationConfig.MARIADB_USER,
                ApplicationConfig.MARIADB_PASSWORD);
        statement = (MariaDbStatement) conn.createStatement();


        return statement;
    }

}