1 25 26 package org.objectweb.jonas.jtests.tables; 27 28 import java.rmi.RemoteException ; 29 import java.sql.Connection ; 30 import java.sql.Statement ; 31 import javax.naming.NamingException ; 32 import org.objectweb.util.monolog.api.BasicLevel; 33 34 38 public class Tointeger extends Tmanager { 39 40 43 public static void init() throws NamingException , RemoteException { 44 mgrInit(); 45 createTable("JT_EtypeOintegerEC"); 46 } 47 48 51 private static void createTable(String name) throws RemoteException { 52 53 Connection conn = null; 55 try { 56 conn = dataSource.getConnection(); 57 } catch (Exception e) { 58 throw new RemoteException ("Cannot get Connection"); 59 } 60 61 Statement stmt; 62 try { 63 stmt = conn.createStatement(); 64 stmt.execute("DROP TABLE " + name); 65 stmt.close(); 66 logger.log(BasicLevel.INFO, "Table " + name + " dropped"); 67 } catch (Exception e) { 68 logger.log(BasicLevel.DEBUG, "Exception in dropTable : \n" + e); 69 } 70 try { 71 String cTypeName = "integer"; stmt = conn.createStatement(); 73 stmt.execute("create table " + name 74 + "( c_pk varchar(30) not null primary key, c_f1 " + cTypeName + ")"); 75 stmt.execute("insert into " + name + " values('pk1', 1)"); 76 stmt.execute("insert into " + name + " values('pk2', 2)"); 77 stmt.execute("insert into " + name + " values('pk3', 3)"); 78 stmt.execute("insert into " + name + " values('pk4', 4)"); 79 stmt.execute("insert into " + name + " values('pk5', 5)"); 80 stmt.execute("insert into " + name + " values('pk5bis', 5)"); 81 stmt.execute("insert into " + name + " values('pktoremove', 10000)"); 82 stmt.execute("insert into " + name + " values('pknull', NULL)"); 83 stmt.execute("insert into " + name + " values('pkchangenull', 10000)"); 84 85 stmt.close(); 86 conn.close(); } catch (Exception e) { 88 logger.log(BasicLevel.ERROR, "Exception in createTable : " + e); 89 throw new RemoteException ("Exception in createTable : " + e); 90 } 91 logger.log(BasicLevel.INFO, "Table " + name + " created"); 92 } 93 94 } 95 | Popular Tags |