Comment implémenter la suppression par lots de données dans la base de données (exemple de code)

Cet article vous présentera comment supprimer des données par lots de la base de données. Il a une certaine valeur de référence. Les amis dans le besoin peuvent s'y référer. J'espère qu'il vous sera utile.

package com.mescs.baseinfo.utils;

import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;/**
 * 
 * 类名：DatabaseUtil  <br />
 *
 * 功能：数据库操作
 *
 */
 public class DatabaseUtil {    
    private final static Logger LOGGER = LoggerFactory.getLogger(DatabaseUtil.class);    
    private static final String DRIVER = "org.firebirdsql.jdbc.FBDriver";    
    private static final String URL = "jdbc:firebirdsql:embedded:mescs.fdb?lc_ctype=UTF8";    
    private static final String USERNAME = "root";    
    private static final String PASSWORD = "root";    
    private static final String SQL = "DELETE FROM ";// 数据库数据库表内容清空
    
    static {        try {
            Class.forName(DRIVER);
        } catch (ClassNotFoundException e) {
            LOGGER.error("数据库驱动加载失败===>>>", e);
        }
    }    /**
     * 获取数据库连接
     *
     * @return     */
    public static Connection getConnection() {
        Connection conn = null;        
        try {
            conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
        } catch (SQLException e) {
            LOGGER.error("数据库连接失败===>>>", e);
        }        return conn;
    }    /**
     * 关闭数据库连接
     * @param conn     */
    public static void closeConnection(Connection conn) {        
       if(conn != null) {            
            try {
                conn.close();
            } catch (SQLException e) {
                LOGGER.error("数据库关闭失败===>>>", e);
            }
        }
    }    /**
     * 获取数据库下的所有表名     */
    public static List<String> getTableNames() {
        List<String> tableNames = new ArrayList<String>();
        Connection conn = getConnection();
        ResultSet rs = null;        
        try {       //获取数据库的元数据
            DatabaseMetaData db = conn.getMetaData();  //从元数据中获取到所有的表名
            rs = db.getTables(null, null, null, new String[] { "TABLE" });            
            while(rs.next()) {
                tableNames.add(rs.getString(3));
            }
        } catch (SQLException e) {
            LOGGER.error("获取数据库表名失败===>>>", e);
        } finally {            try {
                rs.close();
                closeConnection(conn);
            } catch (SQLException e) {
                LOGGER.error("关闭数据库失败===>>>", e);
            }
        }        return tableNames;
    }    /*
     * 清空数据库表     */
    public static void emptyDatabase() throws SQLException {
        List<String> tableNames = getTableNames();
        Connection conn = getConnection();
        PreparedStatement pStemt = null;        
        for(String table:tableNames){            
             if(!table.equals("SYSPARAM") && !table.equals("T_CLEAR_DATA")){
                String tableSql = SQL + table;                
                try {
                    pStemt = conn.prepareStatement(tableSql);
                    Statement stmt=conn.createStatement();
                    stmt.executeUpdate(tableSql);
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
        conn.close();
    }
}

Résumé : La base de données Firebird utilisée dans la base de données ici peut bien sûr être utilisée dans des bases de données traditionnelles telles que Mysql et Oracle. La méthode consiste simplement à répertorier les suppressions, ajouter, supprimer, modifier et archiver. de la même manière.

Recommandations associées :

Tutoriel graphique de base de données MySQL

Tutoriel vidéo MySQL

Tutoriel vidéo bootstrap

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!