www.pudn.com > SwtDemo.rar > HsqlSimpleApp.java

 
 
package src; 
import java.sql.DriverManager; 
import java.sql.Connection; 
import java.sql.Statement; 
import java.sql.ResultSet; 
import java.sql.SQLException; 
 
import java.util.Properties; 
 
public class HsqlSimpleApp { 
    public String framework = "embedded"; 
    public String driver = "org.hsqldb.jdbcDriver"; 
    public String protocol = "jdbc:hsqldb:"; 
 
   
  /*  public static void main(String[] args) { 
	String id="58634410"; 
	String name="Lqm";                   ///查询时区分大小写 
	new HsqlSimpleApp().go(id,name); 
		 
    } 
     
  */ 
	 
     
    void go(String id,String name) { 
		 
		  String userid=id; 
		  String username=name; 
		   
/*		  System.out.println("------*****选出ID*****----------"); 
		  System.out.println(userid); 
		  System.out.println(username); 
		  System.out.println("------*****选出ID*****----------"); 
*/		   
		  System.out.println("HsqlSimpleApp starting in " + framework + " mode.");	 
          try { 
             
            Class.forName(driver).newInstance(); 
            System.out.println("Loaded the appropriate driver."); 
			 
            String user          = "sa"; 
	        String password      = ""; 
	        String getColumnName = "false"; 
 
	        Properties props = new Properties(); 
 
			props.put("user", user); 
			props.put("password", password); 
	        props.put("jdbc.strict_md", "false"); 
			props.put("jdbc.get_column_name", getColumnName); 
 
		 
			Connection conn = DriverManager.getConnection(protocol + "mydb1", props); 
            System.out.println("Connected to and created database HsqlDB"); 
			 
            /* 
			We could also turn autocommit off by putting 
			;autocommit=false on the URL. 
			*/ 
            conn.setAutoCommit(false); 
			 
            /* 
      			 Creating a statement lets us issue commands against 
      			 the connection. 
	    	*/ 
            Statement s = conn.createStatement(); 
			 
            /* 
	      	  We create a table and adding a few rows. 
	    	*/ 
            s.execute("CREATE TABLE Stuff(Id varchar(10), FirstName varchar(30), LastName varchar(30), Department varchar(255))"); 
          //  System.out.println("Created table Stuff"); 
            s.execute("INSERT INTO Stuff VALUES('033776618','Yinnon', 'Haviv', 'CS')"); 
          //  System.out.println("Inserted ('033776618','Yinnon', 'Haviv', 'CS')"); 
            s.execute("INSERT INTO Stuff VALUES('032290835','Enav', 'Weinrebe', 'CS')"); 
          //  System.out.println("Inserted ('032290835','Enav', 'Weinrebe', 'CS')"); 
            s.execute("INSERT INTO Stuff VALUES('030776163','Luba', 'Kogan', 'MATH')"); 
          //  System.out.println("Inserted ('030776163','Luba', 'Kogan', 'MATH')"); 
            s.execute("INSERT INTO Stuff VALUES('056084080','Amir', 'Sapir', 'CS')"); 
           // System.out.println("Inserted ('056084080','Amir', 'Sapir', 'CS')"); 
		    s.execute("INSERT INTO Stuff VALUES('58634410','Lqm', 'Jelver', 'MATH')"); 
           // System.out.println("Inserted ('58634410','Lqm', 'Jelver', 'MATH')"); 
             
            /*  
            		here is an example of updating rows in the table 
            */ 
             
            s.execute("UPDATE Stuff set LastName='Sapir' where ID='030776163'"); 
          //  System.out.println("Changing Luba Kogan -> Luba Sapir"); 
 
            /* 
            		here we query the database 
            		1. getting Names of all the stuff according the LastName,First 
            		2. getting ID of all the members of the CS department. 
            */ 
 
						 	 
            System.out.println("------*****选出LastName,FirstName*****----------"); 
            ResultSet rsAllStuff = s.executeQuery("SELECT *  FROM Stuff  WHERE Id like '%"+userid+"%' and FirstName like '%"+username+"%' ");    /// '和"之间不能为空哦！！ 
            while (rsAllStuff.next()) 
            { 
            	System.out.print("FirstName is ："); 
            	System.out.println(rsAllStuff.getString("FirstName"));  
            	System.out.print("LastName is ："); 
                System.out.println(rsAllStuff.getString("LastName")); 
                System.out.println("--------------------------"); 
            } 
            System.out.println("------*****选出LastName,FirstName*****----------"); 
            rsAllStuff.close(); // don't forget close the recordset. 
            System.out.println("rsAllStuff RecordSet closed"); 
             
			/* 
			here we are dropping (deleting) the table - this is no a usual thing to do... 
		    */ 
 
			s.execute("drop table Stuff"); 
			System.out.println("Dropped table Stuff"); 
			 
            /* 
	    	We release statement resource. 
	    	*/ 
            s.close(); 
            System.out.println("Closed statement"); 
			 
            /* 
	      				We end the transaction and the connection. 
	    				*/ 
            conn.commit(); 
            conn.close(); 
            System.out.println("Committed transaction and closed connection"); 
			 
            boolean gotSQLExc = false; 
            if (framework.equals("embedded")) { 
                try { 
                    DriverManager.getConnection("jdbc:Hsql:;shutdown=true"); 
                } catch (SQLException se) { 
                    gotSQLExc = true; 
                } 
                if (!gotSQLExc) 
                    System.out.println("Database did not shut down normally"); 
                else 
                    System.out.println("Database shut down normally"); 
	    } 
	} 
	catch (Throwable e) { 
	    System.out.println("exception thrown:"); 
			 
            if (e instanceof SQLException)  
                printSQLError((SQLException)e); 
            else 
                e.printStackTrace(); 
        } 
		 
        System.out.println("HsqlSimpleApp finished"); 
    } 
	 
    static void printSQLError(SQLException e) { 
        while (e != null) { 
            System.out.println(e.toString()); 
            e = e.getNextException(); 
        } 
    } 
		 
}