testSODA.java

importjava.sql.Connection;
importjava.sql.DriverManager;
importoracle.sql.*;
importoracle.soda.rdbms.OracleRDBMSClient;

importoracle.soda.OracleDatabase;
importoracle.soda.OracleCursor;
importoracle.soda.OracleCollection;
importoracle.soda.OracleDocument;
importoracle.soda.OracleException;

importjava.util.Properties;

importoracle.jdbc.OracleConnection;
importoracle.jdbc.pool.OracleDataSource;

publicclasstestSODA {
publicstaticvoidmain(String[] args) {

// SODA works on top of a regular JDBC connection.

Connectionconn = null;

try {
/*
 * Where is your code running: in the database or outside?
 */
if (System.getProperty("oracle.jserver.version") != null)
 {
/*
 * You are in the database, already connected, use the default connection
 *
 */
OracleDataSourceods = newOracleDataSource();
ods.setURL("jdbc:default:connection");
conn = ods.getConnection();
 }
else {
/*
 * You are not in the database, you need to connect thru the client driver
 */
// Set up the connection string: replace hostName, port, and serviceName
// with the info for your Oracle RDBMS instance
Stringurl = "jdbc:oracle:thin:@//hostName:port/serviceName";

Propertiesprops = newProperties();
// Replace with your schemaName and password
props.setProperty("user", "schemaName");
props.setProperty("password", "password");

conn = (OracleConnection) DriverManager.getConnection(url, props);
 }
// Get an OracleRDBMSClient - starting point of SODA for Java application
OracleRDBMSClientcl = newOracleRDBMSClient();

// Get a database
OracleDatabasedb = cl.getDatabase(conn);

//Check whether the named collection already exists or not
OracleCollectioncol = db.openCollection("MyFirstJSONCollection");
if (col != null) col.admin().drop();

// Create a collection with the name "MyFirstJSONCollection".
// Note: Collection names are case-sensitive.
// A table with the name "MyFirstJSONCollection" will be
// created in the RDBMS to store the collection
col = db.admin().createCollection("MyFirstJSONCollection");

// Create a few JSON documents, representing
// users and the number of friends they have
OracleDocumentdoc1 =
db.createDocumentFromString(
"{ \"name\" : \"Alex\", \"friends\" : \"50\" }");

OracleDocumentdoc2 =
db.createDocumentFromString(
"{ \"name\" : \"Mia\", \"friends\" : \"300\" }");

OracleDocumentdoc3 =
db.createDocumentFromString(
"{ \"name\" : \"Gloria\", \"friends\" : \"399\" }");

// Insert the documents into a collection, one-by-one.
// The result documents contain auto-generated
// keys, among other documents components (version, etc).
// Note: SODA provides the more efficient bulk insert as well
OracleDocumentresultDoc1 = col.insertAndGet(doc1);
OracleDocumentresultDoc2 = col.insertAndGet(doc2);
OracleDocumentresultDoc3 = col.insertAndGet(doc3);

// Retrieve the first document using its auto-generated
// unique ID (aka key)
System.out.println ("* Retrieving the first document by its key *\n");

OracleDocumentfetchedDoc = col.find().key(resultDoc1.getKey()).getOne();

System.out.println (fetchedDoc.getContentAsString());

// Retrieve all documents representing users that have
// 300 or more friends. Use the following query-by-example:
// {friends : {$gte : 300}}.
System.out.println ("\n* Retrieving documents representing users with" +
" at least 300 friends *\n");

OracleDocumentf = db.createDocumentFromString(
"{ \"friends\" : { \"$gte\" : 300 }}");

OracleCursorc = null;

try {
// Get a cursor over all documents in the collection
// that match our query-by-example
c = col.find().filter(f).getCursor();

while (c.hasNext()) {
// Get the next document
fetchedDoc = c.next();

System.out.println (fetchedDoc.getContentAsString());
 }
 }
finally {
// Important: you must close the cursor to release resources!
if (c != null) {
c.close();
 }
 }

// Drop the collection, deleting the table backing
// it and collection metadata
if (args.length > 0 && args[0].equals("drop")) {
col.admin().drop();
System.out.println ("\n* Collection dropped *");
 }
 }
catch (Exceptione) {
e.printStackTrace();
 }
finally {
if (conn != null) {
try {
conn.close();
 }
catch (Exceptione) {
 }
 }
 }
 }
}