targetdatabase.java

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

package com.unimas.dbsync.output;

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

/**
 * Created by IntelliJ IDEA.
 * User: Administrator
 * Date: 2008-12-10
 * Time: 11:17:01
 */
public class TargetDataBase {
    private static TargetDataBase databaseUtils = null;
    //以下数据应从配置文件中获取
    private static String driverClass = "org.gjt.mm.mysql.Driver";
    private static String driverUrl = "jdbc:mysql://localhost:3306/new_db?useUnicode=true&characterEncoding=utf8";
    private static String dbUsername = "root";
    private static String dbPassword = "6437120";

    private TargetDataBase() {

    }

    public static TargetDataBase getInstance() {
        if (databaseUtils == null) {
            databaseUtils = new TargetDataBase();
        }
        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();
            }
        }
    }
}