deletetabrecords.java

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

package com.unimas.dbsync.output;


import com.unimas.dbsync.entity.TargetTabBaseBean;

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


/**
 * Created by IntelliJ IDEA.
 * User: Administrator
 * Date: 2008-12-15
 * Time: 15:00:46.
 */

/**
 * 删除目标端数据库的要被插入信息的表中的所有记录
 */
public class DeleteTabRecords {
    /**
     *
     * @param bean 目标端数据库中的表对象
     */
    public static void deleteTabRecords(TargetTabBaseBean bean) {
        Connection conn = null;
        Statement statement = null;
        String TabName = bean.getTableName();
        try {
            conn = TargetDataBase.getInstance().getConnection();//连接目标端数据库
            statement = conn.createStatement();
            statement.executeQuery("delete from" + TabName);  //执行delete语句 清空该表的所有记录
        } catch (SQLException e) {
          e.printStackTrace();
        } catch (ClassNotFoundException e) {
          e.printStackTrace();
        } finally {
            if (statement != null) {
                try {
                    statement.close();
                } catch (SQLException sqlE) {
                    sqlE.printStackTrace();
                }
            }
            TargetDataBase.getInstance().closeConnection(conn); //关闭数据库连接
        }
    }
}