package spilog;
/*
 * 1.Read the file line by line,
 * 2.Split the line into multiple words using StringTokenizer and Tab ("\t") as delimeter.
 * 3.Create insert query (if the table is existing, otherwise create it) and
 * add the query to a batch using, statement.addBatch(query);
 * 4.Finally execute the batch, statement.executeBatch();
 * */
 
/*import packages */
import java.io.*;
import java.sql.*;
import java.util.*;
 
public class test {
 
		public static void main (String[] args) {
			String TABLE_NAME = "LogSPI01",
			HOST = "jdbc:odbc:spimon",
			DRIVER = "sun.jdbc.odbc.JdbcOdbcDriver",
			FILENAME = "F:\\SPI01.log";
			try {
				// connect to db
				Class.forName(DRIVER).newInstance();
				Connection con = DriverManager.getConnection(HOST,"","");
				PreparedStatement ps = null;
				// open text file
				BufferedReader in = new BufferedReader(new FileReader(FILENAME));
				String line=in.readLine();
				while((line=in.readLine()) != null) {
					System.out.println(line);
					// read and parse a line
					StringTokenizer tk = new StringTokenizer(line,"\t");
					if(tk.countTokens()>=10) {
 
						String PCB  	= tk.nextToken(),
						FAIL_COUNT		= tk.nextToken(),
						DATE 			= tk.nextToken(),
						TIME 			= tk.nextToken();
 
						// execute SQL insert statement
						//String query = "INSERT INTO 1 VALUES(FailureID_CSV,Fail_Qty,DATE_OCURRANCE,TIME_OCURRANCE)";
						String query = "INSERT INTO LogSPI01 VALUES(?,?,?,?)";
						ps = con.prepareStatement(query);
						ps.setString(1,PCB);
						ps.setString(2,FAIL_COUNT);
						ps.setString(3,DATE);
						ps.setString(4,TIME);
 
						ps.executeUpdate(query);
					} 
					else {
						System.out.println("Error:");
					}
				}
				in.close();
				con.close();
			} catch( Exception e) {
				e.printStackTrace();
			}
		}
	}

package spilog;
 
 
import java.io.*;
import java.sql.*;
import java.io.BufferedReader;
import java.io.FileReader;
 
class Database {
 
	public static void main (String args[]) {
 
 
		Database myprog = new Database();
		myprog.readFile();
		System.out.println("done");
	} // end main
 
	void readFile() {
 
		String record;
 
	try {
 
		BufferedReader inputStream = new BufferedReader(new FileReader("F:\\SPI01.log"));
		record = new String();
 
 
		while ((record = inputStream.readLine()) != null) {
			String st = record;
			String []splitSt = st.split(",");
			System.out.println("string : " +st);
					System.out.println("length :" + splitSt.length);
					int i;
 
					//Connecting to the database
					//String URL =
					//"jdbc:odbc:Driver={Microsoft Access Driver (*.mdb)};DBQ=E:\\public\\Log\\Results\\spimon.mdb;}",
					String HOST = "jdbc:odbc:spimon",
					DRIVER = "sun.jdbc.odbc.JdbcOdbcDriver";
					Class.forName(DRIVER).newInstance();
					Connection myConn = DriverManager.getConnection(HOST,"","");
					//Connection myConn = DriverManager.getConnection(URL,"","");
 
 
					//using the database 
					Statement stat = myConn.createStatement();
					PreparedStatement updaterecord;
					String query="INSERT INTO logspi01 VALUES(?,?,?,?)"; //tem que ter o mesmo numero de campos da DB
					updaterecord=myConn.prepareStatement(query);
 
 
					for (i = 0; i < splitSt.length; i++ )
					{
						updaterecord.setString ((i+1), splitSt[i]);
					}
					updaterecord.executeUpdate();
 
					stat.close();
					myConn.close(); 
		}//end while
	} catch (IOException e) {
//		catch possible io errors from readLine()
		System.out.println("IOException error: ");
		e.printStackTrace();
	}
	catch (Exception ex) 
	{ 
		ex.printStackTrace();
	}
	} 
}

if (fdir.getPath().endsWith(".csv") && fdir.lastModified() > HostFile.lastModified())
				System.out.println(INDENTS[depth] + fdir.getName() +", "+ countline +","+Date.format(nDate));

package spilog;
 
 
import java.io.*;
import java.sql.*;
import java.io.BufferedReader;
import java.io.FileReader;
 
class Database {
 
	public static void main (String args[]) {
 
 
		Database myprog = new Database();
		myprog.readFile();
		System.out.println("done");
	} // end main
 
	void readFile() {
 
		Connection myConn = null;
		String record;
 
		try {
 
			//BufferedReader inputStream = new BufferedReader(new FileReader("F:\\SPI01.log"));
			BufferedReader inputStream = new BufferedReader(new FileReader("E:\\public\\Log\\SPIlog.txt"));
			record = new String();
 
 
 
 
			while ((record = inputStream.readLine()) != null) {
				//if(record.trim().length() == 0) {
				record=record.trim();
				if (record.equalsIgnoreCase("\n")==false){ 
 
					/* Check for characters '#' and replace with ',' */
					char [][] maps = {{'R', ' '},{'.', ' '},{'S', ' '},{'E', ' '},{'F', ','},};
					for (int i = 0; i<maps.length; ++i)
					{
						record = record.replace(maps[i][0], maps[i][1]);
					}
 
					String st = record;
					String []splitSt = st.split(",");
 
 
 
					System.out.println("string : " + st );
 
 
					System.out.println("length :" + splitSt.length );
					int i;
 
					//Connecting to the database
					//String URL =
					//"jdbc:odbc:Driver={Microsoft Access Driver (*.mdb)};DBQ=E:\\public\\Log\\Results\\spimon.mdb;}",
					String HOST = "jdbc:odbc:spimon",
					DRIVER = "sun.jdbc.odbc.JdbcOdbcDriver";
					Class.forName(DRIVER).newInstance();
					myConn = DriverManager.getConnection(HOST,"","");
					//Connection myConn = DriverManager.getConnection(URL,"","");
 
 
					//using the database 
					Statement stat = myConn.createStatement();
					PreparedStatement updaterecord;
					String query="INSERT INTO logspi01 VALUES(?,?,?,?,?,?,?)"; //tem que ter o mesmo numero de campos da DB
					updaterecord = myConn.prepareStatement(query,Statement.RETURN_GENERATED_KEYS);
 
 
					for (i = 0; i < splitSt.length; i++ )
					{
						//updaterecord.setString ((i+1), splitSt[i]); /*or*/
						updaterecord.setString((1)," "); 		//machine
 
						updaterecord.setString((2),splitSt[0]); //package
						updaterecord.setString((3)," ");		//lotnumber
						updaterecord.setString((4),splitSt[1]);	//Fail Location - (primary Key)
						updaterecord.setString((5),splitSt[2]);	//Fail Qty
						updaterecord.setString((6),splitSt[3]);	//Date
						updaterecord.setString((7),splitSt[4]);	//Time
//						updaterecord.setString((1),splitSt[0]);
//						updaterecord.setString((2),splitSt[1]);
//						updaterecord.setString((3)," ");
//						updaterecord.setString((4),splitSt[3]);
//						updaterecord.setString((5),splitSt[4]);
//						updaterecord.setString((6),splitSt[5]);
//						updaterecord.setString((7),splitSt[6]);
					}
					updaterecord.executeUpdate();
					int x = updaterecord.executeUpdate();
					stat.close();
					myConn.close();
					myConn = null;
					System.out.println("  Inserting Data " + x + " row(s)");
 
				}//end while
			} 
		}
		catch (IOException e) 
		{
			/* catch possible io errors from readLine() */
			System.out.println("IOException error: ");
			e.printStackTrace();
		}
		catch (Exception ex) 
		{ 
			ex.printStackTrace();
		}
		finally
		{
		if (myConn != null) try {myConn.close();
		}
		catch (Exception ignore){}
		}
	}
} 
 
/**
 * Keep an ArrayList of the "keys" (those fields which iniquely identify the record), then use contains before adding the record.
 
Another way, would be to define a "primary key" in the table, then simply attempt to insert the records and catch the "duplicate key" SQLException.
 
 * 
 * 
 * Do you know what a try/catch block is (I hope you do if you're using JDBC)? If so, then, simply put the execute statement for the insert inside of its own try/catch block, and when the insert fails due to duplicate keys, simply ignore that record and go on to the next. 
Java Programmer and Sun Systems Administrator
 */
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
///*
//import java.io.*;
//import java.sql.SQLException;
//import java.util.*;
 
//public class T3 {
//public static void main (String[] args){
 
//String line = null;
//boolean first = true;
//int count = 51;
//int rowNum = 0;
//String[] fieldlist = new String[count];
//String monTable = "LogSPI1";
//BufferredReader reader = null;
//Connection con = null;
//Statement stmt = null; 
//String url = "jdbc:odbc:Driver={Microsoft Access Driver " +
//"(*.mdb)};DBQ=c:/MyDocu~1/pyxis.mdb";
////HOST = "jdbc:odbc:spimon";
 
//try {
//Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
//con = DriverManager.getConnection (url, "", ""); 
//stmt = con.createStatement ( );
//} catch (ClassNotFoundException e){
//System.err.println ("Unsuccesful loading : " + e.getMessage ( )); 
//} catch (SQLException ex){ 
//System.out.println ("con object error " + ex.getMessage( )); 
//}
 
 
//try{
//reader = new BufferedReader(new FileReader("F:\\SPI01.log"));
//} catch (FileNotFoundException e){ 
//System.out.println ("Check the file name/path.") 
//System.exit (); 
//}
 
//while ((line = reader.readLine ()) != null ){ 
//if (first) { 
//first = false; 
//rowNum++;
//continue; 
//}
 
//StringTokenizer tok = new StringTokenizer (line, ",", true ); 
//if( tok.countTokens() != count ) {
//System.out.println("Problem at row number " + rowNum);
//System.exit(); 
//} 
////parse fields 
//for( int field = 0; field < count; field++ ) { 
//String token = tok.nextToken (); 
////remove "," at the end 
//fieldlist[field] = token.substring (0, token.length()-1); 
//} 
 
////create insert command - handle each field as text 
//String insert = "INSERT INTO monTable values(fieldlist[0]";
//for (int field = 1; field < count; field++){
//insert += "," + fieldlist[field];
//}
//insert += ")";
 
//try {
//stmt.executeUpdate( insert );
//} catch (SQLException e) {
//System.out.println ("SQL error " + et.getMessage ( ) );
//}
//}
 
//reader.close ( );
//stmt.close ( );
//con.close ( ); 
 
//}
//} 
 
//}*/