testcsv.java

数据仓库工具

package org.relique.jdbc.csv;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;

public class TestCsv {
  static long startTime = System.currentTimeMillis();
  public static void main(String arg[]) {
	try {

	Class.forName("org.relique.jdbc.csv.CsvDriver");
	Connection con = DriverManager.getConnection(
		"jdbc:relique:csv:/TestCsv;create=true");
	con.setAutoCommit(false);
	String query = "";

/* CREATE TABLE */

//	  query =
//		  "CREATE TABLE NABAVIO (S_ART VARCHAR(10), S_NAB VARCHAR(10), CENA_NAB VARCHAR(10), NAB_KOL VARCHAR(10), DATUM VARCHAR(10))";
//	  query = "UPDATE NAMES SET ime='zo=''ranaa' WHERE prezime='milako==vic'";
//	  query = "INSERT INTO NAMES ( ime, prezime, selo ) VALUES ( 'zo=ran', 'milako''vic', '' )";
	  query = "create table TEST ( ime VARCHAR,\n prezime VARCHAR,\n slika BINARY,\n grad VARCHAR\n)";
	  Statement stmtCreate = con.createStatement();
	  stmtCreate.execute(query);
	  con.commit();

/* INSERT */
	  query = "insert into test (ime, prezime, grad) values ( 'sl\"a''vko', 'pe,ric', '' )";
	  Statement stmt = con.createStatement();
	  stmt.executeUpdate(query);
	  con.commit();
	
	  PreparedStatement pstmt = con.prepareStatement("update test set ime=? where ime=? ");
	  pstmt.setString(1, "slavko");
	  pstmt.setString(2, "sl\"a''vko");
	  pstmt = con.prepareStatement("insert into test (ime, prezime, slika, grad) values (?,?,?,?) ");

	  File file = new File("/TestCsv/Check.gif");
	  FileInputStream fos = new FileInputStream(file);
	  byte[] fileBytes = new byte[(int)file.length()];
	  fos.read(fileBytes);
	  for (int i = 0; i < 1 ;i++ ) {
		pstmt.setString(1, "Pera");
		pstmt.setString(2, null);
		pstmt.setBytes(3, fileBytes);
		pstmt.setString(4, "Novi Sad");
		pstmt.executeUpdate();
		pstmt.clearParameters();
	  }
	  con.commit();


/* SELECT */

	query = "select * from test";
	Statement stmt1 = con.createStatement();
	ResultSet rset = stmt1.executeQuery( query );
//	  ResultSet rset = con.getMetaData().getTables(null, null, null, null);
		int i = 0;
	  while( rset.next() ) {
		  File ofile = new File("/TestCsv/checkRestore"+i+".gif");
		  FileOutputStream fw = new FileOutputStream(ofile);
		  if( rset.getBytes(3) != null )
			fw.write(rset.getBytes(3));
		  i++;
		  System.out.println(rset.getString(1));
		  System.out.println(rset.getString(2));
		  System.out.println(rset.getBytes(3));
		  System.out.println(rset.getString("grad"));
		  System.out.println("***********");
	  }
//	  stmt.executeUpdate(query);


	} catch( Exception e ) {
	  e.printStackTrace();
	}
  }
}