-1

您好我正在尝试读取读取表名和列名以进行 sql 查询以进行测试验证

我有一个 .ctl 文件,其中包含如图所示的表格详细信息

LOAD DATA APPEND
  INTO TABLE ALM_LAV_CD_BSTG
FIELDS TERMINATED BY '~~' 
TRAILING NULLCOLS                                                               
(                                                                               
   ALM_VERS_ID                      DECIMAL EXTERNAL NULLIF (ALM_VERS_ID=BLANKS)
 , LAV_CD                           CHAR NULLIF (LAV_CD=BLANKS)                 
 , LAV_CD_OFSE                      INTEGER EXTERNAL NULLIF (LAV_CD_OFSE=BLANKS)
 , LAV_CD_AMT                       DECIMAL EXTERNAL NULLIF (LAV_CD_AMT=BLANKS) 
 , EXPRT_DT                         DATE "YYYY-MM-DD"
 , DUA_INSRT_ID                     CHAR NULLIF (DUA_INSRT_ID=BLANKS)           
 , DUA_INSRT_TMSTP                  TIMESTAMP "YYYY-MM-DD HH24:MI:SS.FF6"                                            
 , DUA_UPDT_ID                      CHAR NULLIF (DUA_UPDT_ID=BLANKS)            
 , DUA_UPDT_TMSTP                   TIMESTAMP "YYYY-MM-DD HH24:MI:SS.FF6"                                            
 , DUA_VERS_NBR                     DECIMAL EXTERNAL NULLIF (DUA_VERS_NBR=BLANKS)                                                                               
)                                                                               

我的要求是将表名读入字符串和列名,忽略 EXPRT_DT 成字符串

我的代码如下

package com.cf.ODSAutomation;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

import javax.swing.filechooser.FileNameExtensionFilter;

public class ReadControlFile {

	public static void main(String[] args) throws Exception {

		// Control Files Folder Path

		File path = new File("C:\\ODS\\control_File");
		final FileNameExtensionFilter extensionFilter = new FileNameExtensionFilter("Control Files", "ctl");
		File[] files = path.listFiles();
		System.out.println("Number of Control Files : " + files.length);

		// Looping the files in the folder

		for (final File file : path.listFiles()) {
			if (extensionFilter.accept(file)) {
				System.out.println("File Name : " + file.getName().trim());
				BufferedReader reader = new BufferedReader(new FileReader(file));
				StringBuilder builder = new StringBuilder();
				String currentLine = reader.readLine();
				while (currentLine != null) {
					builder.append(currentLine);
					builder.append("\n");
					currentLine = reader.readLine();
				}

				// Appending all lines into single line
				System.out.println(builder.toString());

				// Getting Table Name
				String temp[] = builder.toString().split("TABLE ");
				String temp1[] = temp[1].split("_BSTG");
				String TableName = temp1[0].trim();
				System.out.println("Table Name : " + TableName);

				Pattern p = Pattern.compile("[a-zA-Z]+_*");

				Matcher m1 = p.matcher(temp[1]);

				System.out.println("Words from string \"" + temp[1] + "\" : ");
				while (m1.find()) {
					System.out.println(m1.group());
				}

				reader.close();

			}
		}

	}

}

我可以使用 Strings 类读取表名,但无法获取列名。

我的愿望结果是将列名附加在一个用逗号分隔的字符串中,如下所示

ALM_VERS_ID,LAV_CD,LAV_CD_OFSE,LAV_CD_AMT,EXPRT_DT,DUA_INSRT_ID,DUA_INSRT_TMSTP,DUA_UPDT_ID,DUA_UPDT_TMSTP,DUA_VERS_NBR

目前我的结果是

ALM_ LAV_ CD_ BSTG FIELDS TERMINATED BY TRAILING NULLCOLS ALM_ VERS_ ID DECIMAL EXTERNAL NULLIF ALM_ VERS_ ID BLANKS LAV_ CD CHAR NULLIF LAV_ CD BLANKS LAV_ CD_ OFSE INTEGER EXTERNAL NULLIF LAV_ CD_ OFSE BLANKS LAV_ CD_ CD_ AMT 十进制外部 NULL IF LAV_ CD_ AMT BLANKS MM DD DUA_ INSRT_ ID CHAR NULLIF DUA_ INSRT_ ID BLANKS DUA_ INSRT_ TMSTP TIMESTAMP YYYY MM DD HH MI SS FF DUA_ UPDT_ ID CHAR NULLIF DUA_ UPDT_ ID BLANKS DUA_ UPDT_ TMSTP TIMESTAMP YYYY MM DD HH MI SS FF DUA_VERS_NBR DECIMAL DUA_ DUA NULL丁腈橡胶毛坯

4

1 回答 1

1

请查看我为您编写的用于处理控制文件的 C# 解决方案。我碰巧将控制文件命名为 *.txt。

编写了一个控制文件解析器来处理表名,每个控制文件的所有列名。

https://github.com/ranjancse26/ControlFileProcessor

您可以轻松地将代码从 C# 反向工程到 Java。

于 2018-07-11T23:56:00.443 回答