Ребят, здравствуйте. Помогите залить CSV файл в таблицу Оракл в поле типа clob. Мне на java надо. Почитала форум (
1 ,
11805350 ), но решения не смогла найти. Вот "мой" код:
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
78.
79.
80.
81.
82.
83.
84.
85.
86.
87.
88.
89.
90.
91.
92.
93.
94.
95.
96.
import java.util.Date;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.sql.*;
public class uploadFile {
/**
* @param args
* @throws IllegalAccessException
* @throws InstantiationException
* @throws ClassNotFoundException
* @throws SQLException
*/
public static final String dbUser = "MAYA";
public static final String dbPassword = "pass";
public static void main(String[] args) throws IllegalAccessException, InstantiationException, ClassNotFoundException, SQLException, FileNotFoundException {
// TODO Auto-generated method stub
// метод который подключается к базе
try {
Class.forName ("oracle.jdbc.OracleDriver");
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
String connectionURL = "jdbc:oracle:thin:@//IP:1521/MAYASCHEMA";
Connection conn = DriverManager.getConnection(connectionURL, dbUser, dbPassword);
conn.setAutoCommit(true);
System.out.println("Connected.\n");
//Потестируем
Statement stmt = conn.createStatement();
ResultSet rset = null;
String sqlText = "Select sysdate from dual";
rset = stmt.executeQuery(sqlText);
if (rset.next()) {
Date currentDate = rset.getDate(1); // get first column returned
System.out.println("Current Date from Oracle is : "+currentDate);
}
rset.close();
stmt.close();
//Попробую загрузить CSV файл в clob поле.
File сlob = new File("D:\\Docs\\input_test.csv");
PreparedStatement pstmt = conn.prepareStatement("INSERT INTO csv_files (id, document_name, csv_document, timestamp) " +
" VALUES(2, '" + сlob.getName() + "', ?, SYSDATE)");
FileInputStream in = new FileInputStream(сlob);
///Дальше не могу =((
//?????
conn.commit();
/**
* Close Oracle database connection.
* @throws java.sql.SQLException
*/
try {
conn.close();
System.out.println("Disconnected.\n");
} catch (SQLException e) {
System.out.println("Caught SQL Exception: (Closing Connection).");
e.printStackTrace();
if (conn != null) {
try {
conn.rollback();
} catch (SQLException e2) {
System.out.println("Caught SQL (Rollback Failed) Exception.");
e2.printStackTrace();
}
}
throw e;
}
}
}
Заранее добра вам. =))
