1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
|
// **********************************************************************
//
// 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 <DeptFactoryI.h>
#include <Util.h>
#include <sqlca.h>
EXEC SQL WHENEVER SQLERROR DO handleSqlError(sqlca, ctx);
using namespace std;
DeptFactoryI::DeptFactoryI(const CurrentSqlContext& currentCtx, const string& deptCategory, const string& empCategory) :
_currentCtx(currentCtx),
_deptCategory(deptCategory),
_empCategory(empCategory)
{
}
HR::DeptPrx
DeptFactoryI::createDept(int key, const HR::DeptDesc& desc, const Ice::Current& current)
{
sqlca sqlca;
EXEC SQL BEGIN DECLARE SECTION;
sql_context ctx = _currentCtx;
int deptno = key;
const char* dname = desc.dname.c_str();
const char* loc = desc.loc.c_str();
EXEC SQL END DECLARE SECTION;
EXEC SQL CONTEXT USE :ctx;
EXEC SQL INSERT INTO DEPT(deptno, dname, loc) VALUES(:deptno, :dname, :loc);
EXEC SQL COMMIT;
Ice::Identity deptId;
deptId.name = encodeName(deptno);
deptId.category = _deptCategory;
return HR::DeptPrx::uncheckedCast(current.adapter->createProxy(deptId));
}
EXEC SQL WHENEVER NOT FOUND DO break;
HR::DeptPrxSeq
DeptFactoryI::findAll(const Ice::Current& current)
{
sqlca sqlca;
EXEC SQL BEGIN DECLARE SECTION;
sql_context ctx = _currentCtx;
int deptno;
EXEC SQL END DECLARE SECTION;
EXEC SQL CONTEXT USE :ctx;
EXEC SQL DECLARE depCursor1 CURSOR FOR SELECT DEPTNO FROM DEPT;
EXEC SQL OPEN depCursor1;
HR::DeptPrxSeq result;
for(;;)
{
EXEC SQL FETCH depCursor1 INTO :deptno;
Ice::Identity deptId;
deptId.category = _deptCategory;
deptId.name = encodeName(deptno);
result.push_back(HR::DeptPrx::uncheckedCast(current.adapter->createProxy(deptId)));
}
EXEC SQL CLOSE depCursor1;
EXEC SQL COMMIT;
return result;
}
HR::DeptPrxSeq
DeptFactoryI::findByName(const string& name, const Ice::Current& current)
{
sqlca sqlca;
EXEC SQL BEGIN DECLARE SECTION;
const char* dname = name.c_str();
sql_context ctx = _currentCtx;
int deptno;
EXEC SQL END DECLARE SECTION;
EXEC SQL CONTEXT USE :ctx;
EXEC SQL DECLARE depCursor2 CURSOR FOR SELECT DEPTNO FROM DEPT WHERE DNAME = :dname;
EXEC SQL OPEN depCursor2;
HR::DeptPrxSeq result;
for(;;)
{
EXEC SQL FETCH depCursor2 INTO :deptno;
Ice::Identity deptId;
deptId.category = _deptCategory;
deptId.name = encodeName(deptno);
result.push_back(HR::DeptPrx::uncheckedCast(current.adapter->createProxy(deptId)));
}
EXEC SQL CLOSE depCursor2;
EXEC SQL COMMIT;
return result;
}
HR::DeptPrx
DeptFactoryI::findDeptByNo(int deptno, const Ice::Current& current)
{
Ice::Identity deptId;
deptId.category = _deptCategory;
deptId.name = encodeName(deptno);
Ice::ObjectPrx prx = current.adapter->createProxy(deptId);
//
// Check that this deptno exists
//
try
{
prx->ice_ping();
}
catch(const Ice::ObjectNotExistException&)
{
return 0;
}
return HR::DeptPrx::uncheckedCast(prx);
}
HR::EmpPrx
DeptFactoryI::findEmpByNo(int empno, const Ice::Current& current)
{
Ice::Identity empId;
empId.category = _empCategory;
empId.name = encodeName(empno);
Ice::ObjectPrx prx = current.adapter->createProxy(empId);
//
// Check that this empno exists
//
try
{
prx->ice_ping();
}
catch(const Ice::ObjectNotExistException&)
{
return 0;
}
return HR::EmpPrx::uncheckedCast(prx);
}
|
