Example Application Using SQL/JDBC

/* @(#) ExampleApp.java ver 1.0 00/08/21 14:43:49
 * ???.java, initial version May 2000
 *
 * Copyright (c) 2000 Northgate Information Solutions Plc.
 * All Rights Reserved.

// Import the required java classes and interfaces

import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.DataTruncation;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
import java.io.*;

public class ExampleApp {

     public static void main(String args[]) {

           Connection con = null;
           Statement stmt = null;
           ResultSet rs = null;
           Properties info = new Properties();
           String driver = "com.northgateis.reality.realsql.RealSQLDriver";
           String url = "jdbc:realsql://magpie:1203/TESTDBASE";

           // Initialise the connection properties
           info.put("user", "ajt");
           info.put("password", "a23Fgh"); //
           info.put("account", "SQL-TEST");
           info.put("accountpwd", "");

           PrintWriter pw = new PrintWriter(System.out);

           DriverManager.setLogWriter(pw);

           ////// REGISTER THE DRIVER AND MAKE A CONNECTION //////

           try {
                // Register the driver and connect to the database
              Class.forName(driver);
                con = DriverManager.getConnection(url, info);
           }
           catch( SQLException e ) {

               System.out.println("Failed to connect to database: " + e.getMessage());
               return;
           }
           catch( ClassNotFoundException e ) {

               System.out.println("Unable to find driver class.");
               return;
           }

           ////// CREATE A STATEMENT AND EXECUTE AN SQL QUERY //////

           try {

               stmt = con.createStatement();

               rs = stmt.executeQuery("SELECT * FROM EMP");
           }
           catch (SQLException sqle) {

               System.out.println("ERROR: " + sqle.getMessage());

           }

         ////// FETCH AND DISPLAY THE RESULTSET //////

         try {

           // Print column labels, padded to correct display size.
           for (int c=1; c<=rs.getMetaData().getColumnCount(); ++c)
           {
              byte[] buf = new byte[rs.getMetaData().getColumnDisplaySize(c) + 1];

              System.arraycopy(rs.getMetaData().getColumnLabel(c).getBytes(),
                    0, buf, 0, rs.getMetaData().getColumnLabel(c).length());

              if (rs.getMetaData().getColumnLabel(c).length() < buf.length)
              {
                  int i;

                  for (i=rs.getMetaData().getColumnLabel(c).length(); i<buf.length; i++
                  {
                      buf[i] = (byte)0x2E; // pad with "."s
                  }

                  buf[i-1] = (byte)0x20; // overwrite last byte with space " "
              }

              System.out.write(buf,0,buf.length);
            }

            System.out.println();

            int numRows =0;

            // Print column data for all rows using column number.
            while (rs.next())
            {
                for (int c=1; c<=rs.getMetaData().getColumnCount(); ++c)
                {
                     String cname = rs.getMetaData().getColumnName(c);
                     String value = rs.getString(c);
                     
                     if (rs.wasNull())
                           value = "";

                     byte[] buf = new byte[rs.getMetaData().getColumnDisplaySize(c) + 1];

                     System.arraycopy(value.getBytes(), 0, buf, 0, value.length());

                     if (value.length() < buf.length)
                     {
                         for (int i=value.length();i<buf.length;i++)
                         {
                             buf[i] = (byte)0x20;
                         }
                     }

                     System.out.write(buf,0,buf.length);
             }

             numRows++;

             System.out.println();
        }

        System.out.println(numRows + " Rows listed.");
   }
   catch (SQLException sqle) {

         System.out.println("ERROR: " + sqle.getMessage());
   }

   try {
        if (rs != null) rs.close();
        if (stmt != null) stmt.close();
        if (con != null) con.close();
   }
   catch (SQLException sqle) { 

        System.out.println("ERROR: " + sqle.getMessage());
 }

}

}