JAVA如何實(shí)現(xiàn)數(shù)據(jù)庫的批處理操作

批量數(shù)據(jù)進(jìn)入數(shù)據(jù)庫使用addBatch()和executeBatch()方法

創(chuàng)新互聯(lián)主要從事成都網(wǎng)站設(shè)計(jì)、做網(wǎng)站、成都外貿(mào)網(wǎng)站建設(shè)公司、網(wǎng)頁設(shè)計(jì)、企業(yè)做網(wǎng)站、公司建網(wǎng)站等業(yè)務(wù)。立足成都服務(wù)洞頭,10年網(wǎng)站建設(shè)經(jīng)驗(yàn),價格優(yōu)惠、服務(wù)專業(yè),歡迎來電咨詢建站服務(wù):13518219792

PreparedStatement.addBatch(); ...... PreparedStatement.executeBatch();需要注意的是一次最多不要超過50條:1.因?yàn)椴迦氲臅r候數(shù)據(jù)庫已經(jīng)鎖定，然而若是一次性插入太多會造成其他業(yè)務(wù)的等待。2.會造成內(nèi)存的溢出

舉例：

PreparedStatement pst = (PreparedStatement) con.prepareStatement("insert into ***** values (?,'***')"); for (int i = 0; i 10000; i++) { pst.setInt(1, i); // 把一個SQL命令加入命令列表 pst.addBatch(); } // 執(zhí)行批量更新 pst.executeBatch(); // 語句執(zhí)行完畢，提交本事務(wù) con.commit();

如何把java中的項(xiàng)目做成批處理？

這是我一個真實(shí)的項(xiàng)目。發(fā)布批處理程序，結(jié)構(gòu)目錄如下：

data文件存放數(shù)據(jù)，etc存放配置文件，lib，存放項(xiàng)目jar包，startup.bat/startup.sh啟動腳本。

1、-----windows上.bat文件調(diào)用java程序。bat文件內(nèi)容如下------

echo?off

rem?setup?classpath

echo?set?_CP=%%_CP%%;%%1?cp.bat

set?_CP=.;\classes;"%JAVA_HOME%\lib\dt.jar";"%JAVA_HOME%\lib\tools.jar"

for?%%i?in?(lib\*.jar)?do?call?cp.bat?%%i

set?CLASSPATH=%_CP%

del?cp.bat

echo?%CLASSPATH%

rem?set?JAVA_HOME=

set?JAVA_OPTION=-Dfile.encoding=GBK?-Xms256m?-Xmx256m?-XX:MaxPermSize=64m

set?RUN_CLASS=batch.Main

"%JAVA_HOME%\bin\java"?%JAVA_OPTION%?-classpath?%CLASSPATH%?%RUN_CLASS%

2、-------unix/linux上shell調(diào)用java程序，shello文件內(nèi)容如下---------

if?[?-z?${JAVA_HOME}?]

then

echo?"JAVA_HOME?not?set?yet,can't?run?java?program!"

exit?-1

fi

CLASSPATH=.:${JAVA_HOME}/lib/tools.jar:${JAVA_HOME}/lib/dt.jar

JLIBDIR=./lib

export?JLIBDIR

for?LL?in?`ls?${JLIBDIR}/*.jar`

do

CLASSPATH=${CLASSPATH}:${LL}

done

echo?${CLASSPATH}

export?CLASSPATH

JAVA_OPTION="-Dfile.encoding=GBK?-Xms256m?-Xmx256m?-XX:MaxPermSize=64m"

RUN_CLASS=batch.Main

${JAVA_HOME}/bin/java?${JAVA_OPTION}?-classpath?${CLASSPATH}?${RUN_CLASS}

java編程 批處理

import java.io.File;

import java.io.FileWriter;

import java.io.IOException;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.ArrayList;

import java.util.Stack;

public class CheckFilebatch {

private static final String LOG_FILE = "F:/CheckFilebatch.log"; //報(bào)錯的信息寫在這個文件里。

private static final String FILE_HOME = "F:/niceStore /"; //要操作的物理目錄

public static void main(String[] args) {

try {

ArrayListString fileListInDB = new ArrayListString();

FileWriter fw = new FileWriter(LOG_FILE);

// TODO

// 取得DB連接，執(zhí)行sql“SELECT DISTINCT FILEPATH FROM ARR-FILE”,得到一個ResultSet

// 從DB中取出文件信息，放入fileListInDB 中，

ResultSet rs = null;

while (rs.next()) {

String path = rs.getString("File_Column");

File f = new File(path);

if (!f.exists()) {

// 不合法的報(bào)出錯誤信息。

System.out.println("file not exists: " + path);

fw.write("file not exists: " + path + "\n");

} else {

// 合法的，轉(zhuǎn)化為路徑名的規(guī)范路徑名字符串，加入到fileListInDB中

fileListInDB.add(f.getCanonicalPath());

}

}

rs.close();

//

fw.write("\n\n\n\n");

//下面開始遍歷物理目錄

File home = new File(FILE_HOME);

StackFile tmpStack = new StackFile();

tmpStack.add(home);

while (!tmpStack.isEmpty()) {

File tmp = tmpStack.pop();

File[] childs = tmp.listFiles();

for (int i = 0; i childs.length; i++) {

File child = childs[i];

if (child.isDirectory()) {

tmpStack.push(child);

} else {

if (fileListInDB.contains(child.getCanonicalPath())) {

fileListInDB.remove(child.getCanonicalPath());

} else {

// 刪除文件。

child.delete();

// 這里的操作如果把它移動到另一個目錄里，作為備份，更好些。

fw.write("delete file: " + child.getCanonicalPath());

}

}

}

}

// 這個程序只考慮文件，不考慮目錄

fw.close();

} catch (SQLException e) {

e.printStackTrace();

} catch (IOException e1) {

e1.printStackTrace();

}

}

}