CsvJdbc - a JDBC driver for CSV files

The driver class is org.relique.jdbc.csv.CsvDriver The connection URL is jdbc:relique:csv:csvdir, where csvdir is the directory in which the .csv files are found.

This example code shows how the driver is used.

import java.sql.*;

public class DemoDriver
{
  public static void main(String[] args)
  {
    try
    {
      // load the driver into memory
      Class.forName("org.relique.jdbc.csv.CsvDriver");

      // create a connection. The first command line parameter is assumed to
      //  be the directory in which the .csv files are held
      Connection conn = DriverManager.getConnection("jdbc:relique:csv:" + args[0] );

      // create a Statement object to execute the query with
      Statement stmt = conn.createStatement();

      // Select the ID and NAME columns from sample.csv
      ResultSet results = stmt.executeQuery("SELECT ID,NAME FROM sample");

      // dump out the results
      while (results.next())
      {
        System.out.println("ID= " + results.getString("ID") + "   NAME= " + results.getString("NAME"));
      }

      // clean up
      results.close();
      stmt.close();
      conn.close();
    }
    catch(Exception e)
    {
      System.out.println("Oops-> " + e);
    }
  }
}

These properties are:

  ...

  Properties props = new java.util.Properties();

  props.put("separator","|");              // separator is a bar
  props.put("suppressHeaders","true");     // first line contains data
  props.put("fileExtension",".txt");       // file extension is .txt
  props.put("charset","ISO-8859-2");       // file encoding is "ISO-8859-2"
  props.put("raiseUnsupportedOperationException","false");       // don't raise unsupported operation exception (when not relevant)

  Connection conn = Drivermanager.getConnection("jdbc:relique:csv:" + args[0],props)

  ...
         

This following example code shows how these are used.

  ...

  Connection conn = Drivermanager.getConnection("jdbc:relique:csv:" + args[0],props)

  Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, 0);

  ResultSet results = stmt.executeQuery("SELECT ID,NAME FROM sample");

  resulst.next();
  ...
  results.first();
  ...
  results.previous();
  ...
  results.relative(2);
  ...
  results.absolute(2);
  ...