diff options
author | Matthew Newhook <matthew@zeroc.com> | 2015-03-18 12:58:16 -0230 |
---|---|---|
committer | Matthew Newhook <matthew@zeroc.com> | 2015-03-18 12:58:16 -0230 |
commit | 9b7668c7c92cf9cb311fe444cdddb489cd2a219d (patch) | |
tree | 5016567c58c81f5654e9d01935e199c6bf4761d2 /cpp/demo/Database/Oracle/occi/DeptFactoryI.cpp | |
parent | VS add-in & build updates: (diff) | |
download | ice-9b7668c7c92cf9cb311fe444cdddb489cd2a219d.tar.bz2 ice-9b7668c7c92cf9cb311fe444cdddb489cd2a219d.tar.xz ice-9b7668c7c92cf9cb311fe444cdddb489cd2a219d.zip |
Removed demos.
Moved demoscript to distribution.
Diffstat (limited to 'cpp/demo/Database/Oracle/occi/DeptFactoryI.cpp')
-rw-r--r-- | cpp/demo/Database/Oracle/occi/DeptFactoryI.cpp | 169 |
1 files changed, 0 insertions, 169 deletions
diff --git a/cpp/demo/Database/Oracle/occi/DeptFactoryI.cpp b/cpp/demo/Database/Oracle/occi/DeptFactoryI.cpp deleted file mode 100644 index bd9284e8780..00000000000 --- a/cpp/demo/Database/Oracle/occi/DeptFactoryI.cpp +++ /dev/null @@ -1,169 +0,0 @@ -// ********************************************************************** -// -// Copyright (c) 2003-2015 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); -} |