Get Stored Procedure Name And Type
import import import import import [Link]; [Link]; [Link]; [Link]; [Link];
public class Main { public static void main(String[] args) throws Exception { Connection conn = getMySqlConnection(); [Link]("Got Connection."); Statement st = [Link](); [Link]("drop table survey;"); [Link]("create table survey (id int,name varchar(30));" ); [Link]("insert into survey (id,name ) values (1,'nameVa lue')"); ResultSet rs = null; DatabaseMetaData meta = [Link](); rs = [Link](null, null, "%"); while ([Link]()) { String spName = [Link]("PROCEDURE_NAME"); int spType = [Link]("PROCEDURE_TYPE"); [Link]("Stored Procedure Name: " + spName); if (spType == [Link]) { [Link]("procedure Returns Result"); } else if (spType == [Link]) { [Link]("procedure No Result"); } else { [Link]("procedure Result unknown"); } } [Link](); [Link]();
private static Connection getHSQLConnection() throws Exception { [Link]("[Link]"); [Link]("Driver Loaded."); String url = "jdbc:hsqldb:data/tutorial"; return [Link](url, "sa", ""); } public static Connection getMySqlConnection() throws Exception { String driver = "[Link]"; String url = "jdbc:mysql://localhost/demo2s"; String username = "oost"; String password = "oost"; [Link](driver); Connection conn = [Link](url, username, pass word); return conn; }
public static Connection getOracleConnection() throws Exception { String driver = "[Link]"; String url = "jdbc:oracle:thin:@localhost:1521:caspian"; String username = "mp"; String password = "mp2"; [Link](driver); // load Oracle driver Connection conn = [Link](url, username, pass word); return conn; } }
Program on inout parameter import import import import [Link]; [Link]; [Link]; [Link];
public class Main { public static void main(String[] argv) throws Exception { String driverName = "[Link]"; [Link](driverName); String String String String String String serverName = "[Link]"; portNumber = "1433"; mydatabase = serverName + ":" + portNumber; url = "jdbc:JSQLConnect://" + mydatabase; username = "username"; password = "password";
Connection connection = [Link](url, username , password); CallableStatement cs = [Link]("{call myprocinout( ?)}"); // Register the type of the IN/OUT parameter [Link](1, [Link]); // Set the value for the IN/OUT parameter [Link](1, "a string"); // Execute the stored procedure and retrieve the IN/OUT value [Link](); String outParam = [Link](1); // OUT parameter [Link](outParam); } }
Program to get the all stored procedure names in database import import import import [Link]; [Link]; [Link]; [Link];
public class Main {
public static void main(String[] argv) throws Exception { String driverName = "[Link]"; [Link](driverName); String String String String String String serverName = "[Link]"; portNumber = "1433"; mydatabase = serverName + ":" + portNumber; url = "jdbc:JSQLConnect://" + mydatabase; username = "username"; password = "password";
Connection connection = [Link](url, username , password); DatabaseMetaData dbmd = [Link](); // Get all stored procedures in any schema and catalog ResultSet resultSet = [Link](null, null, "%"); // Get stored procedure names from the result set while ([Link]()) { String procName = [Link](3); [Link](procName); } } }
Insert a Text file into oracle import import import import import [Link]; [Link]; [Link]; [Link]; [Link];
public class InsertTextFileToOracle { public static Connection getConnection() throws Exception { String driver = "[Link]"; String url = "jdbc:oracle:thin:@localhost:1521:oracle"; String username = "username"; String password = "password"; [Link](driver); Connection conn = [Link](url, username, pass word); return conn; } public static void main(String[] args)throws Exception { String id = "001"; String fileName = "[Link]"; FileInputStream fis = null; PreparedStatement pstmt = null; Connection conn = null; try { conn = getConnection(); [Link](false); File file = new File(fileName); fis = new FileInputStream(file); pstmt = [Link]("insert into DataFiles(id, fileNa
me, fileBody) values (?, ?, ?)"); [Link](1, id); [Link](2, fileName); [Link](3, fis, (int) [Link]()); [Link](); [Link](); } catch (Exception e) { [Link]("Error: " + [Link]()); [Link](); } finally { [Link](); [Link](); [Link](); } } }
Serialized And Deserialize Object Oracle
import import import import import import import import import import import [Link]; [Link]; [Link]; [Link]; [Link]; [Link]; [Link]; [Link]; [Link]; [Link]; [Link];
import [Link]; /**** CREATE TABLE java_objects (object_id NUMBER, object_name varchar(128) , object_value BLOB DEFAULT empty_blob(), primary key (object_id)); SQL> desc java_objects; Name Null? Type ----------------------------------------- -------- --------------------------OBJECT_ID NOT NULL NUMBER OBJECT_NAME VARCHAR2(128) OBJECT_VALUE BLOB SQL> select SEQUENCE_NAME, MIN_VALUE, MAX_VALUE, INCREMENT_BY, LAST_N UMBER from user_sequences; SEQUENCE_NAME MIN_VALUE MAX_VALUE INCREMENT_BY LAS T_NUMBER ------------------------------ ---------- ---------- ------------ ---------ID_SEQ 1 1.0000E+27 1 21 JAVA_OBJECT_SEQUENCE 1 1.0000E+27 1 1 */ public class Main { public static void main(String[] args) throws Exception { String WRITE_OBJECT_SQL = "BEGIN "
value) "
+ "
INSERT INTO java_objects(object_id, object_name, object_
+ " VALUES (?, ?, empty_blob()) " + " RETURN object_value I NTO ?; " + "END;"; String READ_OBJECT_SQL = "SELECT object_value FROM java_objects W HERE object_id = ?"; Connection conn = getOracleConnection(); [Link](false); List<Object> list = new ArrayList<Object>(); [Link]("This is a short string."); [Link](new Integer(1234)); [Link](new [Link]()); // write object to Oracle long id = 0001; String className = [Link]().getName(); CallableStatement cstmt = [Link](WRITE_OBJECT_SQL); [Link](1, id); [Link](2, className); [Link](3, [Link]); [Link](); BLOB blob = (BLOB) [Link](3); OutputStream os = [Link](); ObjectOutputStream oop = new ObjectOutputStream(os); [Link](list); [Link](); [Link](); [Link](); // Read object from oracle PreparedStatement pstmt = [Link](READ_OBJECT_SQL); [Link](1, id); ResultSet rs = [Link](); [Link](); InputStream is = [Link](1).getBinaryStream(); ObjectInputStream oip = new ObjectInputStream(is); Object object = [Link](); className = [Link]().getName(); [Link](); [Link](); [Link](); [Link](); [Link](); // de-serialize list a java object from a given objectID List listFromDatabase = (List) object; [Link]("[After De-Serialization] list=" + listFromDat abase); [Link](); } private static Connection getHSQLConnection() throws Exception { [Link]("[Link]"); [Link]("Driver Loaded."); String url = "jdbc:hsqldb:data/tutorial"; return [Link](url, "sa", ""); }
public static Connection getMySqlConnection() throws Exception { String driver = "[Link]"; String url = "jdbc:mysql://localhost/demo2s"; String username = "oost"; String password = "oost"; [Link](driver); Connection conn = [Link](url, username, pass word); return conn; } public static Connection getOracleConnection() throws Exception { String driver = "[Link]"; String url = "jdbc:oracle:thin:@localhost:1521:databaseName"; String username = "userName"; String password = "password"; [Link](driver); // load Oracle driver Connection conn = [Link](url, username, pass word); return conn; } }
Insert BLOG(Picture or Photo) Data Type Into Oracle Database
import import import import import import import [Link]; [Link]; [Link]; [Link]; [Link]; [Link]; [Link];
import [Link]; public class Main { public static void main(String[] args) throws Exception { Connection conn = getOracleConnection(); int rows = 0; FileInputStream fin = null; OutputStream out = null; ResultSet rs = null; Statement stmt = null; [Link] photo = null; [Link](false); stmt = [Link](); String id = "001"; String binaryFileName = "[Link]"; rows = [Link]("insert into my_pictures(id, photo ) va lues ('" + id + "', empty_blob() )"); [Link](rows + " rows inserted"); rs = [Link]("select photo from my_pictures where id =
'" + id
+ "' for update nowait"); [Link](); photo = ((OracleResultSet) rs).getBLOB(1); fin = new FileInputStream(new File(binaryFileName)); out = [Link](); // Get the optimal buffer size from the BLOB byte[] buffer = new byte[[Link]()]; int length = 0; while ((length = [Link](buffer)) != -1) { [Link](buffer, 0, length); } [Link](); [Link](); [Link](); [Link](); [Link](); [Link]();
} private static Connection getHSQLConnection() throws Exception { [Link]("[Link]"); [Link]("Driver Loaded."); String url = "jdbc:hsqldb:data/tutorial"; return [Link](url, "sa", ""); } public static Connection getMySqlConnection() throws Exception { String driver = "[Link]"; String url = "jdbc:mysql://localhost/demo2s"; String username = "oost"; String password = "oost"; [Link](driver); Connection conn = [Link](url, username, pass word); return conn; } public static Connection getOracleConnection() throws Exception { String driver = "[Link]"; String url = "jdbc:oracle:thin:@localhost:1521:databaseName"; String username = "userName"; String password = "password"; [Link](driver); // load Oracle driver Connection conn = [Link](url, username, pass word); return conn; } }
