sourcedatabase.java

一个简单的数据库同步系统

package com.unimas.dbsync.input;

import java.sql.*;

/**
 * 实现与数据库连接
 */

public class SourceDataBase {
    private static SourceDataBase databaseUtils = null;
    //从配置文件中获取以下数据
    private String driverClass = "org.gjt.mm.mysql.Driver";
    private String driverUrl = "jdbc:mysql://localhost:3306/new_db?useUnicode=true&characterEncoding=utf8";
    private String dbUsername = "root";
    private String dbPassword = "6437120";

    private SourceDataBase() {

    }

    public static SourceDataBase getInstance() {
        if (databaseUtils == null) {
            databaseUtils = new SourceDataBase();
        }
        return databaseUtils;
    }


    /**
     * 创建数据库链接
     *
     * @return
     * @throws ClassNotFoundException
     * @throws java.sql.SQLException
     */
    public Connection getConnection() throws ClassNotFoundException, SQLException {
        Class.forName(driverClass);
        return DriverManager.getConnection(driverUrl, dbUsername, dbPassword);
    }

    /**
     * 关闭 数据库连接
     *
     * @param conn
     */

    public void closeConnection(Connection conn) {
        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException sqle) {
                sqle.printStackTrace();
            }
        }
    }
}