1 files changed, 166 insertions, 0 deletions
diff --git a/java/demo/Database/library/Server.java b/java/demo/Database/library/Server.java
new file mode 100644
index 00000000000..8421b277e44
--- /dev/null
+++ b/java/demo/Database/library/Server.java
@@ -0,0 +1,166 @@
+// **********************************************************************
+//
+// 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.*;
+
+class LibraryServer extends Ice.Application
+{
+    static class LocatorI implements Ice.ServantLocator
+    {
+        LocatorI(Ice.Logger logger, ConnectionPool pool, Ice.Object bookServant, Ice.Object libraryServant)
+        {
+            _logger = logger;
+            _pool = pool;
+            _bookServant = bookServant;
+            _libraryServant = libraryServant;
+        }
+
+        public Ice.Object
+        locate(Ice.Current c, Ice.LocalObjectHolder cookie)
+        {
+            assert c.id.category.equals("library") || c.id.category.equals("book");
+
+            // Setup the new SQL request context.
+            SQLRequestContext context = new SQLRequestContext(_logger, _pool);
+
+            if(c.id.category.equals("library"))
+            {
+                return _libraryServant;
+            }
+            else //if(c.id.category.equals("book"))
+            {
+                return _bookServant;
+            }
+        }
+
+        public void
+        finished(Ice.Current c, Ice.Object servant, Object cookie)
+        {
+            // If a SQL request context is still associated with this
+            // request, then destroy it (it will not be associated if
+            // obtain was called).
+            SQLRequestContext context = SQLRequestContext.getCurrentContext();
+            if(context != null)
+            {
+                context.destroyFromLocator();
+            }
+        }
+
+        public void
+        deactivate(String category)
+        {
+        }
+
+        private Ice.Logger _logger;
+        private ConnectionPool _pool;
+
+        private Ice.Object _bookServant;
+        private Ice.Object _libraryServant;
+    }
+
+    public int
+    run(String[] args)
+    {
+        if(args.length > 0)
+        {
+            System.err.println(appName() + ": too many arguments");
+            return 1;
+        }
+
+        Ice.Properties properties = communicator().getProperties();
+
+        String username = properties.getProperty("JDBC.Username");
+        String password = properties.getProperty("JDBC.Password");
+        String url = properties.getProperty("JDBC.Url");
+        int nConnections = properties.getPropertyAsIntWithDefault("JDBC.NumConnections", 5);
+        if(nConnections < 1)
+        {
+            nConnections = 1;
+        }
+        ConnectionPool pool = null;
+        Ice.Logger logger = communicator().getLogger();
+
+        try
+        {
+            Class.forName ("com.mysql.jdbc.Driver").newInstance();
+        }
+        catch(Exception e)
+        {
+            java.io.StringWriter sw = new java.io.StringWriter();
+            java.io.PrintWriter pw = new java.io.PrintWriter(sw);
+            e.printStackTrace(pw);
+            pw.flush();
+            System.err.println("failed to initialize mysql driver:\n" + sw.toString());
+            return 1;
+        }
+
+        try
+        {
+            pool = new ConnectionPool(logger, url, username, password, nConnections);
+        }
+        catch(java.sql.SQLException e)
+        {
+            java.io.StringWriter sw = new java.io.StringWriter();
+            java.io.PrintWriter pw = new java.io.PrintWriter(sw);
+            e.printStackTrace(pw);
+            pw.flush();
+            System.err.println("failed to create connection pool: SQLException:\n" + sw.toString());
+            return 1;
+        }
+
+        ReapThread reaper = new ReapThread(logger);
+        reaper.start();
+
+        //
+        // Create an object adapter
+        //
+        Ice.ObjectAdapter adapter = communicator().createObjectAdapter("SessionFactory");
+
+        LocatorI locator = new LocatorI(logger, pool, new BookI(logger), new LibraryI(logger));
+
+        adapter.add(new SessionFactoryI(logger, reaper), communicator().stringToIdentity("SessionFactory"));
+        adapter.add(new Glacier2SessionManagerI(logger, reaper),
+                    communicator().stringToIdentity("LibrarySessionManager"));
+
+        adapter.addServantLocator(locator, "book");
+        adapter.addServantLocator(locator, "library");
+
+        //
+        // Everything ok, let's go.
+        //
+        adapter.activate();
+
+        shutdownOnInterrupt();
+        communicator().waitForShutdown();
+        defaultInterrupt();
+
+        reaper.terminate();
+        try
+        {
+            reaper.join();
+        }
+        catch(InterruptedException e)
+        {
+        }
+
+        pool.destroy();
+
+        return 0;
+    }
+}
+
+public class Server
+{
+    static public void
+    main(String[] args)
+    {
+        LibraryServer app = new LibraryServer();
+        app.main("demo.Database.library.Server", args, "config.server");
+    }
+}