From 66e2e230634b41a44981c339c9d03a442107da89 Mon Sep 17 00:00:00 2001
From: prabatuty <prabatuty>
Date: Thu, 15 May 2008 07:43:51 +0000
Subject: [PATCH] adding jdbc example for gateway

---
 examples/jdbc/Makefile       |  5 ++-
 examples/jdbc/gwexample.java | 77 ++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 81 insertions(+), 1 deletion(-)
 create mode 100644 examples/jdbc/gwexample.java

diff --git a/examples/jdbc/Makefile b/examples/jdbc/Makefile
index 6418da31..220e929b 100644
--- a/examples/jdbc/Makefile
+++ b/examples/jdbc/Makefile
@@ -1,7 +1,10 @@
 OSNAME = $(shell  uname -s)
 JAVAC = javac
-TARGETS = jdbcexample
+TARGETS = jdbcexample gwexample
+all: ${TARGETS}
 jdbcexample: jdbcexample.java
 	javac jdbcexample.java
+gwexample: gwexample.java
+	javac gwexample.java
 clean:
 	rm -rf *.class
diff --git a/examples/jdbc/gwexample.java b/examples/jdbc/gwexample.java
new file mode 100644
index 00000000..3fc648ea
--- /dev/null
+++ b/examples/jdbc/gwexample.java
@@ -0,0 +1,77 @@
+import java.sql.*;
+public class gwexample 
+{
+   public static void main(String[] args) 
+   {
+       try
+       {
+          Class.forName("csql.jdbc.JdbcSqlDriver");
+          Connection con = DriverManager.getConnection("jdbc:gateway", "root", "manager");
+          Statement cStmt = con.createStatement();
+
+          PreparedStatement stmt = null, selStmt= null;
+          stmt = con.prepareStatement("INSERT INTO t1 (f1, f2) VALUES (?, ?);");
+          int count =0;
+          int ret =0;
+          for (int i =0 ; i< 10 ; i++) {
+             stmt.setInt(1, i);
+             stmt.setString(2, String.valueOf(i+100));
+             ret = stmt.executeUpdate();
+             if (ret != 1) break; //error
+             count++;
+           }
+           stmt.close();
+           con.commit();
+           System.out.println("Total Rows inserted " + count);
+
+           count =0;
+           stmt = con.prepareStatement("UPDATE t1 SET f2 = ? WHERE f1 = ?;");
+           for (int i =0 ; i< 10 ; i +=2) {
+             stmt.setString(1, String.valueOf(i+200));
+             stmt.setInt(2, i);
+             ret = stmt.executeUpdate();
+             if (ret != 1) break; //error
+             count++;
+           }
+           stmt.close();
+           con.commit();
+           System.out.println("Total Rows updated " + count);
+       
+           count =0;
+           stmt = con.prepareStatement("DELETE FROM t1 WHERE f1 = ?;");
+           for (int i =0 ; i< 10 ; i +=3) {
+             stmt.setInt(1, i);
+             ret = stmt.executeUpdate();
+             if (ret != 1) break; //error
+             count++;
+           }
+           stmt.close();
+           con.commit();
+           System.out.println("Total Rows deleted " + count);
+
+           count =0;
+           selStmt = con.prepareStatement("SELECT * from t1 where f1 = ?;");
+           ResultSet rs = null;
+           for (int i =0 ; i< 10 ; i++) {
+             selStmt.setInt(1, i);
+             rs = selStmt.executeQuery();
+             while (rs.next())
+             {
+                System.out.println("Tuple value is " + rs.getInt(1)+ " "+ rs.getString(2));
+                count++;
+             }
+             rs.close();
+           }
+           selStmt.close();
+           con.commit();
+           System.out.println("Total Rows selected " + count);
+           con.close();
+           }
+        catch(Exception e) {
+           System.out.println("Exception in Test: "+e);
+            e.printStackTrace();
+        }
+       
+    }
+}
+
-- 
2.11.4.GIT