summaryrefslogtreecommitdiff
path: root/java/demo/Database/library/BookI.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/demo/Database/library/BookI.java')
-rw-r--r--java/demo/Database/library/BookI.java435
1 files changed, 435 insertions, 0 deletions
diff --git a/java/demo/Database/library/BookI.java b/java/demo/Database/library/BookI.java
new file mode 100644
index 00000000000..ef9df529608
--- /dev/null
+++ b/java/demo/Database/library/BookI.java
@@ -0,0 +1,435 @@
+// **********************************************************************
+//
+// Copyright (c) 2003-2008 ZeroC, Inc. All rights reserved.
+//
+// This copy of Ice is licensed to you under the terms described in the
+// ICE_LICENSE file included in this distribution.
+//
+// **********************************************************************
+
+import Demo.*;
+
+// This servant is a default servant. The book identity is retreived
+// from Ice.Current object.
+class BookI extends _BookDisp
+{
+ public void
+ ice_ping(Ice.Current current)
+ {
+ Integer id = new Integer(current.id.name);
+
+ java.sql.Connection conn = _pool.acquire();
+ try
+ {
+ java.sql.PreparedStatement stmt = null;
+ try
+ {
+ stmt = conn.prepareStatement("SELECT * FROM books WHERE id = ?");
+ stmt.setInt(1, id);
+ java.sql.ResultSet rs = stmt.executeQuery();
+ if(!rs.next())
+ {
+ throw new Ice.ObjectNotExistException();
+ }
+ }
+ finally
+ {
+ if(stmt != null)
+ {
+ stmt.close();
+ }
+ }
+ }
+ catch(java.sql.SQLException e)
+ {
+ // Log the error, and raise an UnknownException.
+ error(e);
+ Ice.UnknownException ex = new Ice.UnknownException();
+ ex.initCause(e);
+ throw ex;
+ }
+ finally
+ {
+ _pool.release(conn);
+ }
+ }
+
+ public BookDescription
+ describe(Ice.Current current)
+ {
+ Integer id = new Integer(current.id.name);
+
+ java.sql.Connection conn = _pool.acquire();
+ try
+ {
+ java.sql.PreparedStatement stmt = null;
+ try
+ {
+ stmt = conn.prepareStatement("SELECT * FROM books WHERE id = ?");
+ stmt.setInt(1, id);
+ java.sql.ResultSet rs = stmt.executeQuery();
+ if(!rs.next())
+ {
+ throw new Ice.ObjectNotExistException();
+ }
+ return extractDescription(conn, rs, current.adapter);
+ }
+ finally
+ {
+ if(stmt != null)
+ {
+ stmt.close();
+ }
+ }
+ }
+ catch(java.sql.SQLException e)
+ {
+ // Log the error, and raise an UnknownException.
+ error(e);
+ Ice.UnknownException ex = new Ice.UnknownException();
+ ex.initCause(e);
+ throw ex;
+ }
+ finally
+ {
+ _pool.release(conn);
+ }
+ }
+
+ public void
+ destroy(Ice.Current current)
+ {
+ Integer id = new Integer(current.id.name);
+ java.sql.Connection conn = _pool.acquire();
+ try
+ {
+ java.sql.PreparedStatement stmt = null;
+ try
+ {
+ stmt = conn.prepareStatement("DELETE FROM books WHERE id = ?");
+ stmt.setInt(1, id);
+ int count = stmt.executeUpdate();
+ if(count == 0)
+ {
+ throw new Ice.ObjectNotExistException();
+ }
+ }
+ finally
+ {
+ if(stmt != null)
+ {
+ stmt.close();
+ }
+ }
+ }
+ catch(java.sql.SQLException e)
+ {
+ // Log the error, and raise an UnknownException.
+ error(e);
+ Ice.UnknownException ex = new Ice.UnknownException();
+ ex.initCause(e);
+ throw ex;
+ }
+ finally
+ {
+ _pool.release(conn);
+ }
+ }
+
+ public String
+ getRenter(Ice.Current current)
+ throws BookNotRentedException
+ {
+ Integer id = new Integer(current.id.name);
+ java.sql.Connection conn = _pool.acquire();
+ try
+ {
+ java.sql.PreparedStatement stmt = null;
+ try
+ {
+ stmt = conn.prepareStatement("SELECT * FROM books WHERE id = ?");
+ stmt.setInt(1, id);
+ java.sql.ResultSet rs = stmt.executeQuery();
+ if(!rs.next())
+ {
+ throw new Ice.ObjectNotExistException();
+ }
+
+ int renterId = rs.getInt("renter_id");
+ if(rs.wasNull())
+ {
+ throw new BookNotRentedException();
+ }
+ stmt.close();
+ stmt = null;
+
+ stmt = conn.prepareStatement("SELECT * FROM customers WHERE id = ?");
+ stmt.setInt(1, renterId);
+ rs = stmt.executeQuery();
+ boolean next = rs.next();
+ assert next;
+ return rs.getString("name");
+ }
+ finally
+ {
+ if(stmt != null)
+ {
+ stmt.close();
+ }
+ }
+ }
+ catch(java.sql.SQLException e)
+ {
+ // Log the error, and raise an UnknownException.
+ error(e);
+ Ice.UnknownException ex = new Ice.UnknownException();
+ ex.initCause(e);
+ throw ex;
+ }
+ finally
+ {
+ _pool.release(conn);
+ }
+ }
+
+ public void
+ rentBook(String name, Ice.Current current)
+ throws BookRentedException
+ {
+ java.sql.Connection conn = _pool.acquire();
+ Integer id = new Integer(current.id.name);
+ try
+ {
+ conn.setAutoCommit(false);
+ java.sql.PreparedStatement stmt = null;
+ try
+ {
+ stmt = conn.prepareStatement("SELECT * FROM books WHERE id = ?");
+ stmt.setInt(1, id);
+ java.sql.ResultSet rs = stmt.executeQuery();
+ if(!rs.next())
+ {
+ throw new Ice.ObjectNotExistException();
+ }
+
+ rs.getInt("renter_id");
+ if(!rs.wasNull())
+ {
+ throw new BookRentedException();
+ }
+ stmt.close();
+ stmt = null;
+
+ stmt = conn.prepareStatement("SELECT * FROM customers WHERE name = ?");
+ stmt.setString(1, name);
+ rs = stmt.executeQuery();
+
+ Integer renterId = null;
+ if(rs.next())
+ {
+ renterId = rs.getInt("id");
+ assert !rs.next();
+ }
+ else
+ {
+ stmt.close();
+ stmt = null;
+
+ stmt = conn.prepareStatement("INSERT into customers (name) VALUES(?)",
+ java.sql.Statement.RETURN_GENERATED_KEYS);
+ stmt.setString(1, name);
+ int count = stmt.executeUpdate();
+ assert count == 1;
+ rs = stmt.getGeneratedKeys();
+ if(!rs.next())
+ {
+ // ERROR:
+ }
+ renterId = rs.getInt(1);
+ }
+ stmt.close();
+ stmt = null;
+
+ stmt = conn.prepareStatement("UPDATE books SET renter_id = ? WHERE id = ?");
+ stmt.setInt(1, renterId);
+ stmt.setInt(2, id);
+ int count = stmt.executeUpdate();
+ assert count == 1;
+
+ // Commit the transaction.
+ conn.commit();
+ }
+ catch(RuntimeException e)
+ {
+ // Rollback any updates.
+ conn.rollback();
+ throw e;
+ }
+ catch(java.sql.SQLException e)
+ {
+ // Rollback any updates.
+ conn.rollback();
+ throw e;
+ }
+ finally
+ {
+ if(stmt != null)
+ {
+ stmt.close();
+ }
+ }
+ }
+ catch(java.sql.SQLException e)
+ {
+ // Log the error, and raise an UnknownException.
+ error(e);
+ Ice.UnknownException ex = new Ice.UnknownException();
+ ex.initCause(e);
+ throw ex;
+ }
+ finally
+ {
+ try
+ {
+ conn.setAutoCommit(true);
+ }
+ catch(java.sql.SQLException e)
+ {
+ // Ignore
+ }
+ _pool.release(conn);
+ }
+ }
+
+ public void
+ returnBook(Ice.Current current)
+ throws BookNotRentedException
+ {
+ Integer id = new Integer(current.id.name);
+ java.sql.Connection conn = _pool.acquire();
+ try
+ {
+ java.sql.PreparedStatement stmt = null;
+ try
+ {
+ stmt = conn.prepareStatement("SELECT * FROM books WHERE id = ?");
+ stmt.setInt(1, id);
+ java.sql.ResultSet rs = stmt.executeQuery();
+ if(!rs.next())
+ {
+ throw new Ice.ObjectNotExistException();
+ }
+ Integer renterId = rs.getInt("renter_id");
+ if(rs.wasNull())
+ {
+ throw new BookNotRentedException();
+ }
+ stmt.close();
+ stmt = null;
+
+ stmt = conn.prepareStatement("UPDATE books SET renter_id = NULL WHERE id = ?");
+ stmt.setInt(1, id);
+ int count = stmt.executeUpdate();
+ assert count == 1;
+ }
+ finally
+ {
+ if(stmt != null)
+ {
+ stmt.close();
+ }
+ }
+ }
+ catch(java.sql.SQLException e)
+ {
+ // Log the error, and raise an UnknownException.
+ error(e);
+ Ice.UnknownException ex = new Ice.UnknownException();
+ ex.initCause(e);
+ throw ex;
+ }
+ finally
+ {
+ _pool.release(conn);
+ }
+ }
+
+ BookI(Ice.Logger logger, ConnectionPool pool)
+ {
+ _logger = logger;
+ _pool = pool;
+ }
+
+ static Ice.Identity
+ createIdentity(Integer bookId)
+ {
+ Ice.Identity id = new Ice.Identity();
+ id.category = "book";
+ id.name = bookId.toString();
+ return id;
+ }
+
+ static BookDescription
+ extractDescription(java.sql.Connection conn, java.sql.ResultSet rs, Ice.ObjectAdapter adapter)
+ throws java.sql.SQLException
+ {
+ Integer id = rs.getInt("id");
+
+ BookDescription desc = new BookDescription();
+ desc.isbn = rs.getString("isbn");
+ desc.title = rs.getString("title");
+ desc.authors = new java.util.LinkedList<String>();
+ desc.proxy = BookPrxHelper.uncheckedCast(adapter.createProxy(createIdentity(id)));
+
+ java.sql.PreparedStatement stmt = null;
+ try
+ {
+ // Query for the rentedBy.
+ Integer renterId = rs.getInt("renter_id");
+ if(!rs.wasNull())
+ {
+ stmt = conn.prepareStatement("SELECT * FROM customers WHERE id = ?");
+ stmt.setInt(1, renterId);
+ java.sql.ResultSet customerRS = stmt.executeQuery();
+ boolean next = customerRS.next();
+ assert next;
+ desc.rentedBy = customerRS.getString(2);
+
+ stmt.close();
+ stmt = null;
+ }
+
+ // Query for the authors.
+ stmt = conn.prepareStatement("SELECT * FROM authors INNER JOIN authors_books ON " +
+ "authors.id=authors_books.author_id AND authors_books.book_id = ?");
+ stmt.setInt(1, id);
+ java.sql.ResultSet authorRS = stmt.executeQuery();
+ while(authorRS.next())
+ {
+ desc.authors.add(authorRS.getString("name"));
+ }
+ }
+ finally
+ {
+ if(stmt != null)
+ {
+ stmt.close();
+ }
+ }
+
+ return desc;
+ }
+
+ private void
+ error(Exception ex)
+ {
+ java.io.StringWriter sw = new java.io.StringWriter();
+ java.io.PrintWriter pw = new java.io.PrintWriter(sw);
+ ex.printStackTrace(pw);
+ pw.flush();
+ _logger.error("BookI: error:\n" + sw.toString());
+ }
+
+ private Ice.Logger _logger;
+ private ConnectionPool _pool;
+}
generated by cgit v1.2.3 (git 2.46.0) at 2025-08-03 20:59:09 +0000