1 files changed, 169 insertions, 0 deletions
diff --git a/cpp/demo/Database/Oracle/occi/DeptFactoryI.cpp b/cpp/demo/Database/Oracle/occi/DeptFactoryI.cpp
new file mode 100644
index 00000000000..a36a069fb11
--- /dev/null
+++ b/cpp/demo/Database/Oracle/occi/DeptFactoryI.cpp
@@ -0,0 +1,169 @@
+// **********************************************************************
+//
+// Copyright (c) 2003-2011 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.
+//
+// **********************************************************************
+
+#include <Ice/Ice.h>
+#include <DeptFactoryI.h>
+#include <Util.h>
+#include <DbTypes.h>
+
+#ifdef _MSC_VER
+//
+// ott generates placement new without the corresponding delete
+//
+#   pragma warning( 4 : 4291 )
+#endif
+
+using namespace std;
+using namespace oracle::occi;
+
+DeptFactoryI::DeptFactoryI(Environment* env, StatelessConnectionPool* pool, 
+                           const string& category) :
+    _env(env),
+    _pool(pool),
+    _category(category)
+{
+}
+
+HR::DeptPrx 
+DeptFactoryI::createDept(int deptno, const HR::DeptDesc& desc, const Ice::Current& current)
+{
+    ConnectionHolderPtr conh = new ConnectionHolder(_pool);
+
+    //
+    // Inserted into the OCCI cache
+    //
+    DEPT_T* dept = new(conh->connection(), "DEPT_VIEW")DEPT_T;
+    dept->setDeptno(deptno);
+    dept->setDname(desc.dname);
+    dept->setLoc(desc.loc);
+ 
+    Ice::Identity deptId;
+    deptId.category = _category;
+    deptId.name = encodeRef(dept->getRef(), _env);
+    conh->commit();
+
+    return HR::DeptPrx::uncheckedCast(current.adapter->createProxy(deptId));
+}
+
+HR::DeptPrxSeq 
+DeptFactoryI::findAll(const Ice::Current& current)
+{
+    HR::DeptPrxSeq result;
+
+    ConnectionHolderPtr conh = new ConnectionHolder(_pool);
+    {
+        StatementHolder stmth(conh);
+    
+        auto_ptr<ResultSet> rs(stmth.statement()->executeQuery("SELECT REF(d) FROM DEPT_VIEW d"));
+        
+        while(rs->next() != ResultSet::END_OF_FETCH)
+        {
+            Ice::Identity deptId;
+            deptId.category = _category;
+            deptId.name = encodeRef(rs->getRef(1), _env);
+            
+            result.push_back(HR::DeptPrx::uncheckedCast(current.adapter->createProxy(deptId)));
+        }
+    }
+    conh->commit();
+    return result;
+}
+
+
+HR::DeptPrxSeq 
+DeptFactoryI::findByName(const string& name, const Ice::Current& current)
+{
+    HR::DeptPrxSeq result;
+    ConnectionHolderPtr conh = new ConnectionHolder(_pool);
+    {
+        StatementHolder stmth(conh);
+        stmth.statement()->setSQL("SELECT REF(d) FROM DEPT_VIEW d WHERE DNAME = :1");
+        stmth.statement()->setString(1, name);
+        
+        auto_ptr<ResultSet> rs(stmth.statement()->executeQuery());
+        
+        while(rs->next() != ResultSet::END_OF_FETCH)
+        {
+            Ice::Identity deptId;
+            deptId.category = _category;
+            deptId.name = encodeRef(rs->getRef(1), _env);
+            
+            result.push_back(HR::DeptPrx::uncheckedCast(current.adapter->createProxy(deptId)));
+        }
+    }
+    conh->commit();
+    return result;
+}
+
+HR::DeptPrx
+DeptFactoryI::findDeptByNo(int deptno, const Ice::Current& current)
+{
+    HR::DeptPrx result;
+
+    ConnectionHolderPtr conh = new ConnectionHolder(_pool);
+    Ref<DEPT_T> ref = findDeptRefByNo(deptno, conh->connection());
+    
+    if(!ref.isNull())
+    {
+        Ice::Identity deptId;
+        deptId.category = _category;
+        deptId.name = encodeRef(ref, _env);
+        result = HR::DeptPrx::uncheckedCast(current.adapter->createProxy(deptId));
+    }
+    conh->commit();
+    return result;
+}
+
+HR::EmpPrx
+DeptFactoryI::findEmpByNo(int empno, const Ice::Current& current)
+{
+    HR::EmpPrx result;
+    ConnectionHolderPtr conh = new ConnectionHolder(_pool);
+    Ref<EMP_T> ref = findEmpRefByNo(empno, conh->connection());
+
+    if(!ref.isNull())
+    {
+        Ice::Identity empId;
+        empId.category = _category;
+        empId.name = encodeRef(ref, _env);
+        result = HR::EmpPrx::uncheckedCast(current.adapter->createProxy(empId));
+    }
+    conh->commit();
+    return result;
+}
+
+Ref<DEPT_T>
+DeptFactoryI::findDeptRefByNo(int deptno, Connection* con) const
+{
+    StatementHolder stmth(con);
+    stmth.statement()->setSQL("SELECT REF(d) FROM DEPT_VIEW d WHERE DEPTNO = :1");
+    stmth.statement()->setInt(1, deptno);
+    auto_ptr<ResultSet> rs(stmth.statement()->executeQuery());
+    
+    if(rs->next() == ResultSet::END_OF_FETCH)
+    {
+        return Ref<DEPT_T>();
+    }
+    return rs->getRef(1);
+}
+
+Ref<EMP_T>
+DeptFactoryI::findEmpRefByNo(int empno, Connection* con) const
+{
+    StatementHolder stmth(con);
+    stmth.statement()->setSQL("SELECT REF(e) FROM EMP_VIEW e WHERE EMPNO = :1");
+    stmth.statement()->setInt(1, empno);
+    auto_ptr<ResultSet> rs(stmth.statement()->executeQuery());
+
+    if(rs->next() == ResultSet::END_OF_FETCH)
+    {
+        return Ref<EMP_T>();
+    }
+    return rs->getRef(1);
+}