String datei;
String trennzeichen = ",";
String ersatzzeichen = "#####";
public Manager datenbank = new Manager();
private PreparedStatement sqlStatement;
public Connection conn;
public CSV(String datei) {
try {
datenbank.connectDB();
this.datei = datei;
String data_Name = (new File(datei).getName().trim());
data_Name = data_Name.substring(0,(data_Name.trim()).length() - 4);
RE trenner = new RE(trennzeichen);
RE ersatz = new RE(ersatzzeichen);
conn = datenbank.getConnection();
Statement s = conn.createStatement();
BufferedReader in = new BufferedReader(new FileReader(datei));
String zeile = in.readLine();
String[] spalten = trenner.split(zeile +1 ) ;
int csv_id = 1;
if(existDB()){
csv_id = get_GroessteID()+ 1;
}
else{
datenbank.createDatenbank();
}
int BodyMedia_ID = get_ID(data_Name);
String sql = "INSERT INTO csv_import(";
sql += "csv_id," ;
for (int i = 0 ; i < spalten.length; i++) {
sql += spalten.replace(". - ","_").replace(" - ","_").replace(". ", "_").replace(" ", "_")
.replace("ö", "oe").replace("ä", "ae").replace("ß", "ss");
if (i != spalten.length - 1 ) {
sql += ","; }
}
sql += ", BodyMedia_ID) VALUES(" + "'" + csv_id + "',";
for (int i = 0 ; i < spalten.length; i++) {
sql += "'" + ersatzzeichen + "'";
if (i != spalten.length - 1 ) sql += ",";
}
sql += ",'" + BodyMedia_ID + "')";
conn.setAutoCommit(false);
while ((zeile = in.readLine()) != null) {
spalten = trenner.split(zeile);
String sqli = sql;
if (!spalten[1].equals("")){
for (int i = 0; i < spalten.length; i++) {
sqli = ersatz.subst(sqli, spalten, RE.REPLACE_FIRSTONLY);
}
s.addBatch(sqli);
}
}
int[] udc = s.executeBatch();
conn.commit();
datenbank.closeDB();
System.out.print("Update Counts");
for (int i = 0; i < udc.length; i++) System.out.print(" ICH binnnnnn" + udc);
}
catch (Exception ex) { ex.printStackTrace(); }
}