1. 資料庫表 users

-- Create table
create table USERS
(
  id       VARCHAR2(32),
  name     VARCHAR2(200),
  password VARCHAR2(200),
  sj       VARCHAR2(200)
);

2. 資料檔案 users.txt ，中間使用的 "Tab" 符號

ID	NAME	PASSWORD	SJ
1	Unmi	3	2018
2	Tony	5	2008
3	張三	8	2009
4	Kypfos	4	2009
5	李四	1	2008

3. ctl檔案 user.ctl

Options (skip=1)
 Load Data Infile 'C:/ctl/users.txt'
 Append into table USERS
 Fields terminated by X'09'
 Optionally enclosed by '"'
 Trailing nullcols (ID,NAME,PASSWORD,SJ)
 

4. 執行 Dos 命令

sqlldr.exe userid=scott/[email protected]:1521/ORCL control=C:/ctl/users.ctl log=C:/ctl/users.log

5. 執行結果圖

6. Java實現

package workbench.functions;

import java.io.BufferedReader;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;

public class Sqlldr {

	/**
	 * 
	 * @param args
	 */
	public static void main(String[] args) {
		// 寫控制檔案.ctl
		String fileRoute = "C:/ctl/";		// 檔案地址路徑
		String fileName = "users.txt";		// 資料檔名
		String tableName = "USERS";			// 表名
		String fieldName = "(ID,NAME,PASSWORD,SJ)"; // 要寫入表的欄位
		String ctlfileName = "users.ctl";	// 控制檔名
		
		ctlFileWriter(fileRoute, fileName, tableName, fieldName, ctlfileName);
		
		// 要執行的DOS命令
		String user = "scoot";
		String psw = "tiger";
		String database = "172.25.21.163:1521/ORCL"; // IP要指向資料庫伺服器的地址
		String logfileName = "users.log";
		
		executeDos(user, psw, database, fileRoute, ctlfileName, logfileName);
	}

	/**
	 * * 寫控制檔案.ctl
	 * @param fileRoute 資料檔案地址路徑
	 * @param fileName  資料檔名
	 * @param tableName 表名
	 * @param fieldName 要寫入表的欄位
	 * @param ctlfileName 控制檔名
	 */
	public static void ctlFileWriter(String fileRoute, String fileName, String tableName, String fieldName, 
			String ctlfileName) {
		
		FileWriter fw = null;
		String strctl = "Options (skip=1)" + 
                        "\n Load Data Infile '" + fileRoute + "" + fileName + "'" + 
                        "\n Append into table " + tableName + "" + 
                        "\n Fields terminated by X'09'" + 
                        "\n Optionally enclosed by '\"'" + 
                        "\n Trailing nullcols " + fieldName + "";
		System.out.println(strctl);
		try {
			fw = new FileWriter(fileRoute + "" + ctlfileName);
			fw.write(strctl);
		} catch (IOException e) {
			e.printStackTrace();
		} finally {
			try {
				fw.flush();
				fw.close();
			} catch (IOException e) {
				e.printStackTrace();
			}

		}
	}
	
	/**
	 * * 呼叫系統DOS命令
	 * @param user
	 * @param psw
	 * @param Database
	 * @param fileRoute
	 * @param ctlfileName
	 * @param logfileName
	 */
	public static void executeDos(String user, String psw, String database, String fileRoute, String ctlfileName,
			String logfileName) {
		InputStream ins = null;
		// 要執行的DOS命令
		String cmd = "sqlldr.exe userid=" + user + 
                     "/" + psw + "@" + database + 
                     " control=" + fileRoute + ctlfileName + 
                     " log=" + fileRoute + logfileName;
		
		try {
			Process process = Runtime.getRuntime().exec(cmd);
			ins = process.getInputStream(); // 獲取執行cmd命令後的資訊

			BufferedReader reader = new BufferedReader(new InputStreamReader(ins));
			String line = null;
			while ((line = reader.readLine()) != null) {
				String msg = new String(line.getBytes("ISO-8859-1"), "UTF-8");
				System.out.println(msg); // 輸出
			}
			int exitValue = process.waitFor();
			if (exitValue == 0) {
				System.out.println("返回值：" + exitValue + "\n資料匯入成功");

			} else {
				System.out.println("返回值：" + exitValue + "\n資料匯入失敗");
			}

			process.getOutputStream().close(); // 關閉
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	
}