Oracle Pro*C demo

1 files changed, 168 insertions, 0 deletions

diff --git a/cpp/demo/Database/Oracle/proc/EmpI.pc b/cpp/demo/Database/Oracle/proc/EmpI.pc
new file mode 100644
index 00000000000..6eb8c6b2c09
--- /dev/null
+++ b/cpp/demo/Database/Oracle/proc/EmpI.pc
@@ -0,0 +1,168 @@
+// **********************************************************************
+//
+// Copyright (c) 2003-2006 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 <EmpI.h>
+#include <Util.h>
+#include <sqlca.h>
+
+EXEC SQL WHENEVER SQLERROR DO handleSqlError(sqlca, ctx);
+
+using namespace std;
+
+
+EmpI::EmpI(const CurrentSqlContext& currentCtx,
+	   const string& empCategory, const string& deptCategory) :
+    _currentCtx(currentCtx), 
+    _empCategory(empCategory), _deptCategory(deptCategory)
+{
+}
+
+void 
+EmpI::ice_ping(const Ice::Current& current)
+{
+    struct sqlca sqlca;
+    EXEC SQL BEGIN DECLARE SECTION;
+    sql_context ctx = _currentCtx;
+    int empno = decodeName(current.id.name);
+    int count = 0;
+    EXEC SQL END DECLARE SECTION;
+
+    EXEC SQL CONTEXT USE :ctx;
+    EXEC SQL SELECT COUNT(*) INTO :count FROM EMP WHERE EMPNO = :empno;
+    EXEC SQL COMMIT;
+
+    if(count == 0)
+    {
+	throw Ice::ObjectNotExistException(__FILE__, __LINE__);
+    }
+}
+
+
+HR::EmpDesc 
+EmpI::getDesc(const Ice::Current& current)
+{
+    struct sqlca sqlca;
+    EXEC SQL BEGIN DECLARE SECTION;
+    sql_context ctx = _currentCtx;
+    int empno = decodeName(current.id.name);
+    char ename[21];
+    short enameInd;
+    char job[10];
+    short jobInd;
+    int mgr;
+    short mgrInd;
+    char hiredate[30];
+    short hiredateInd;
+    char sal[11];
+    short salInd;
+    char comm[11];
+    short commInd;
+    int deptno;
+    short deptnoInd;
+    EXEC SQL END DECLARE SECTION;
+    
+    EXEC SQL CONTEXT USE :ctx;
+    EXEC SQL SELECT ENAME, JOB, MGR, HIREDATE, SAL, COMM, DEPTNO 
+	     INTO :ename:enameInd, :job:jobInd, :mgr:mgrInd, 
+	          :hiredate:hiredateInd, :sal:salInd, :comm:commInd, :deptno:deptnoInd
+             FROM EMP WHERE EMPNO = :empno;
+    EXEC SQL COMMIT;
+    
+    HR::EmpDesc result;
+    if(enameInd >= 0)
+    {
+	result.ename = ename;
+    }
+    if(jobInd >= 0)
+    {
+	result.job = job;
+    }
+    if(mgrInd >= 0)
+    {
+	Ice::Identity mgrId;
+	mgrId.name = encodeName(mgr);
+	mgrId.category = _empCategory;
+	result.mgr = HR::EmpPrx::uncheckedCast(current.adapter->createProxy(mgrId));
+    }
+    if(hiredateInd >= 0)
+    {
+	result.hiredate = hiredate;
+    }
+    if(salInd >= 0)
+    {
+	result.sal = sal;
+    }
+    if(commInd >= 0)
+    {
+	result.comm = comm;
+    }
+    if(deptnoInd >= 0)
+    {
+	Ice::Identity deptId;
+	deptId.name = encodeName(deptno);
+	deptId.category = _deptCategory;
+	result.edept = HR::DeptPrx::uncheckedCast(current.adapter->createProxy(deptId));
+    }
+    return result;
+}
+    
+void EmpI::updateDesc(const HR::EmpDesc& newDesc, const Ice::Current& current)
+{
+    struct sqlca sqlca;
+    EXEC SQL BEGIN DECLARE SECTION;
+    sql_context ctx = _currentCtx;
+    int empno = decodeName(current.id.name);
+    const char* ename = newDesc.ename.c_str();
+    const char* job = newDesc.job.c_str();
+    int mgr = 0;
+    short mgrInd = 0;
+    const char* hiredate = newDesc.hiredate.c_str();
+    const char* sal = newDesc.sal.c_str();
+    const char* comm = newDesc.comm.c_str();
+    int deptno = 0;
+    short deptnoInd = 0;
+    EXEC SQL END DECLARE SECTION;
+    if(newDesc.mgr == 0)
+    {
+	mgrInd = -1;
+    }
+    else
+    {
+	mgr = decodeName(newDesc.mgr->ice_getIdentity().name);
+    }
+    if(newDesc.edept == 0)
+    {
+	deptnoInd = -1;
+    }
+    else
+    {
+	deptno = decodeName(newDesc.edept->ice_getIdentity().name);
+    }
+
+    EXEC SQL CONTEXT USE :ctx;
+    EXEC SQL UPDATE EMP
+             SET ENAME = :ename, JOB = :job, MGR = :mgr:mgrInd, HIREDATE = :hiredate,
+	         SAL = :sal, COMM = :comm, DEPTNO = :deptno:deptnoInd
+             WHERE EMPNO = :empno;
+    EXEC SQL COMMIT;
+}
+
+void EmpI::remove(const Ice::Current& current)
+{
+    struct sqlca sqlca;
+    EXEC SQL BEGIN DECLARE SECTION;
+    sql_context ctx = _currentCtx;
+    int empno = decodeName(current.id.name);
+    EXEC SQL END DECLARE SECTION;
+
+    EXEC SQL CONTEXT USE :ctx;
+    EXEC SQL DELETE FROM EMP WHERE EMPNO = :empno;
+    EXEC SQL COMMIT;
+}
+