1 files changed, 169 insertions, 0 deletions
diff --git a/cpp/demo/Database/Oracle/occi/DeptI.cpp b/cpp/demo/Database/Oracle/occi/DeptI.cpp
new file mode 100644
index 00000000000..3181ed143fc
--- /dev/null
+++ b/cpp/demo/Database/Oracle/occi/DeptI.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 <DeptI.h>
+
+#ifdef _MSC_VER
+//
+// ott generates placement new without the corresponding delete
+//
+#   pragma warning( 4 : 4291 )
+#endif
+
+using namespace std;
+using namespace oracle::occi;
+
+DeptI::DeptI(const RefAny& ref, const ConnectionHolderPtr& conh, const DeptFactoryIPtr& factory) :
+    _ref(ref), _conh(conh), _factory(factory)
+{
+}
+
+
+HR::EmpPrx 
+DeptI::createEmp(int empno, const HR::EmpDesc& desc, const Ice::Current& current)
+{
+    Environment* env = _factory->getEnv();
+
+    //
+    // Inserted into the OCCI cache
+    //
+    EMP_T* emp = new(_conh->connection(), "EMP_VIEW")EMP_T;
+        
+    emp->setEmpno(empno);
+    emp->setEname(desc.ename);
+    emp->setJob(desc.job);
+    if(desc.mgr != 0)
+    {
+        Ref<EMP_T> mgrRef = decodeRef(desc.mgr->ice_getIdentity().name, env, _conh->connection());
+        
+        emp->setMgrref(mgrRef);
+    }
+    
+    if(desc.hiredate != "")
+    {
+        Date hiredate(env);
+        hiredate.fromText(desc.hiredate);
+        emp->setHiredate(hiredate);
+    }
+    
+    if(desc.sal != "")
+    {
+        Number sal(0);
+        sal.fromText(env, desc.sal, "99999.99");
+        emp->setSal(sal);
+    }
+    
+    if(desc.comm != "")
+    {
+        Number comm(0);
+        comm.fromText(env, desc.comm, "0.999");
+        emp->setComm(comm);
+    }
+    
+    emp->setDeptref(_ref);
+    
+    Ice::Identity empId;
+    empId.category = _factory->getCategory();
+    empId.name = encodeRef(emp->getRef(), env);
+    _conh->commit();
+    return HR::EmpPrx::uncheckedCast(current.adapter->createProxy(empId));
+}
+
+HR::DeptDesc 
+DeptI::getDesc(const Ice::Current& current)
+{
+    HR::DeptDesc result;
+   
+    Ref<DEPT_T> deptRef = decodeRef(current.id.name, _factory->getEnv(), _conh->connection());
+    result.deptno = deptRef->getDeptno();
+    result.dname = deptRef->getDname();
+    result.loc = deptRef->getLoc();
+   
+    _conh->commit();
+    return result;
+}
+    
+void 
+DeptI::updateField(const string& field, const string& newValue, const Ice::Current& current)
+{
+    Ref<DEPT_T> deptRef = decodeRef(current.id.name, _factory->getEnv(), _conh->connection());
+            
+    if(field == "dname")
+    {
+        deptRef->setDname(newValue);
+    }
+    else if(field == "loc")
+    {
+        deptRef->setLoc(newValue);
+    }
+    else
+    {
+        throw HR::SqlException("There is no field " + field + " in object DEPT_T");
+    }
+    deptRef->markModified();
+    _conh->commit();
+}
+
+void 
+DeptI::remove(const Ice::Current& current)
+{
+    Ref<DEPT_T> deptRef = decodeRef(current.id.name, _factory->getEnv(), _conh->connection());
+    deptRef->markDelete();
+    _conh->commit();
+}
+
+HR::EmpPrxSeq 
+DeptI::findAll(const Ice::Current& current)
+{
+    HR::EmpPrxSeq result;
+    {
+        Ref<DEPT_T> deptRef = decodeRef(current.id.name, _factory->getEnv(), _conh->connection());
+
+        StatementHolder stmth(_conh);
+        stmth.statement()->setSQL("SELECT REF(e) FROM EMP_VIEW e WHERE DEPTREF = :1");
+        stmth.statement()->setRef(1, deptRef);
+        auto_ptr<ResultSet> rs(stmth.statement()->executeQuery());
+        
+        while(rs->next() != ResultSet::END_OF_FETCH)
+        {
+            Ice::Identity empId;
+            empId.category = _factory->getCategory();
+            empId.name = encodeRef(rs->getRef(1), _factory->getEnv());
+            result.push_back(HR::EmpPrx::uncheckedCast(current.adapter->createProxy(empId)));
+        }
+    }
+    _conh->commit();
+    return result;
+}
+
+HR::EmpPrxSeq 
+DeptI::findByName(const string& name, const Ice::Current& current)
+{
+    HR::EmpPrxSeq result;
+    {
+        Ref<DEPT_T> deptRef = decodeRef(current.id.name, _factory->getEnv(), _conh->connection());      
+
+        StatementHolder stmth(_conh);
+        stmth.statement()->setSQL("SELECT REF(e) FROM EMP_VIEW e WHERE DEPTREF = :1 AND ENAME = :2");
+        stmth.statement()->setRef(1, deptRef);
+        stmth.statement()->setString(2, name);
+        auto_ptr<ResultSet> rs(stmth.statement()->executeQuery());
+        
+        while(rs->next() != ResultSet::END_OF_FETCH)
+        {
+            Ice::Identity empId;
+            empId.category = _factory->getCategory();
+            empId.name = encodeRef(rs->getRef(1), _factory->getEnv());
+            
+            result.push_back(HR::EmpPrx::uncheckedCast(current.adapter->createProxy(empId)));
+        }
+    }
+    _conh->commit();
+    return result;
+}