hikaku.java

package com.tis.genshinhikaku;

import java.io.BufferedReader;

import java.io.FileReader;

import java.io.IOException;

import java.sql.SQLException;

public class hiKaku {

public static void main(String[] args) throws IOException, SQLException {

readCsvFile readCsvFile = new readCsvFile();

readDabase rData = new readDabase();

readCsvFile.readCsv();

//rData.connectDB();

rData.selectRecordsFromDbStudent();

}

}

---

objectInfo.java

package com.tis.genshinhikaku;

public class objectInfo {

private String tableNameNew;

private String tableNameOld;

private String tableNameResult;

private String objectName;

private String objectKey;

private String objectFlag;

private String table;

public String getTableNameNew() {

return tableNameNew;

}

public void setTableNameNew(String tableNameNew) {

this.tableNameNew = tableNameNew;

}

public String getTableNameOld() {

return tableNameOld;

}

public void setTableNameOld(String tableNameOld) {

this.tableNameOld = tableNameOld;

}

public String getTableNameResult() {

return tableNameResult;

}

public void setTableNameResult(String tableNameResult) {

this.tableNameResult = tableNameResult;

}

public String getObjectName() {

return objectName;

}

public void setObjectName(String objectName) {

this.objectName = objectName;

}

public String getObjectKey() {

return objectKey;

}

public void setObjectKey(String objectKey) {

this.objectKey = objectKey;

}

public String getObjectFlag() {

return objectFlag;

}

public void setObjectFlag(String objectFlag) {

this.objectFlag = objectFlag;

}

public String getTable() {

return table;

}

public void setTable(String table) {

this.table = table;

}

}

---

readCsvFile.java

package com.tis.genshinhikaku;

import java.io.BufferedReader;

import java.io.FileNotFoundException;

import java.io.FileReader;

import java.io.IOException;

import java.util.ArrayList;

import java.util.List;

public class readCsvFile {

public  void readCsv() throws IOException {

String line = "";

String file = "D://IBM/csv/data.txt";

objectInfo info = new objectInfo();

try(BufferedReader br = new BufferedReader(new FileReader(file))) {

info.setTable(br.readLine());

info.setObjectName(br.readLine());

info.setObjectKey(br.readLine());

info.setObjectFlag(br.readLine());

} catch (FileNotFoundException e) {

//Some error logging

}

}

}

---

readDatabase.java

package com.tis.genshinhikaku;

import java.sql.*;

public class readDabase {

String jdbcClassName="com.ibm.db2.jcc.DB2Driver";

String url="jdbc:db2://localhost:50000/sample";

String user="db2admin";

String password="admin";

Statement stmt;

ResultSet rs;

public Connection connectDB () {

Connection connection = null;

try {

//Load class into memory

Class.forName(jdbcClassName);

//Establish connection

connection = DriverManager.getConnection(url, user, password);

System.out.println("Connecting!.");

} catch (ClassNotFoundException e) {

e.printStackTrace();

} catch (SQLException e) {

e.printStackTrace();

}

return connection;

}

public void closeDbConnect(Connection conn) {

if (conn != null) {

System.out.println("Connected successfully.");

try {

conn.close();

System.out.println("Connected successfully.");

} catch (SQLException e) {

e.printStackTrace();

}

}

}

public void selectRecordsFromDbStudent() throws SQLException{

try {

Connection dbConnection = null;

Statement statement = null;

String selectTableSQL = "SELECT * FROM DYL.'student'";

dbConnection = connectDB();

statement = dbConnection.createStatement();

System.out.println(selectTableSQL);

ResultSet rs = statement.executeQuery(selectTableSQL);

while (rs.next()) {

System.out.println("get records");

}

}catch (SQLException e) {

System.out.println(e.getMessage());

}

}

}