The Java Program: Retrieve.java

  1 import java.sql.Driver;
  2 import java.sql.DriverManager;
  3 import java.sql.DriverPropertyInfo;
  4 import java.sql.Statement;
  5 import java.sql.Connection;
  6 import java.sql.ResultSet;
  7 import java.sql.SQLException;
  8 import java.util.*;
  9 
 10 /*
 11   Make sure drivers are on classpath
 12 */
 13 public class Retrieve {
 14    final static String url = "jdbc:mysql://localhost/test?user="+System.getProperty("user.name");
 15    final static String del = "DROP TABLE COFFEES";
 16    final static String create =
 17       "CREATE TABLE COFFEES (COF_NAME VARCHAR(32), SUB_ID INTEGER, PRICE FLOAT, SALES INTEGER, TOTAL INTEGER)";
 18    final static String query = "SELECT COF_NAME, PRICE FROM COFFEES";
 19 
 20    public static void main (String [] args) {
 21       try {
 22          // Some JVMs get confused, so use "newInstance()"
 23          Class.forName("org.gjt.mm.mysql.Driver").newInstance();
 24          final Connection c = DriverManager.getConnection(url);
 25          final Statement stmt = c.createStatement ();
 26          final ResultSet rs = stmt.executeQuery (query);
 27          while (rs.next()) {
 28             final String s = rs.getString ("COF_NAME");
 29             final float p = rs.getFloat("PRICE");
 30             System.out.println (s + "  " + p);
 31          }
 32          stmt.close();
 33          c.close();
 34             
 35       } catch (SQLException e) {
 36          System.out.println("SQLException: " + e.getMessage());
 37          System.out.println("SQLState:     " + e.getSQLState());
 38          System.out.println("VendorError:  " + e.getErrorCode());
 39       } catch (ClassNotFoundException e) {
 40          e.printStackTrace();
 41       } catch (InstantiationException e) {
 42          e.printStackTrace();
 43       } catch (IllegalAccessException e) {
 44          e.printStackTrace();
 45       }
 46    }
 47 
 48 }