blob: 7d2a9ac9ab9115cd6b00b73ab0dbb85e52be10ef (
plain)
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
|
// **********************************************************************
//
// Copyright (c) 2003-2008 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.
//
// **********************************************************************
import Demo.*;
class BookQueryResultI extends _BookQueryResultDisp
{
// The query result owns the SQLRequestContext object until
// destroyed.
BookQueryResultI(SQLRequestContext context, java.sql.ResultSet rs)
{
_context = context;
_rs = rs;
}
synchronized public java.util.List<BookDescription>
next(int n, Ice.BooleanHolder destroyed, Ice.Current current)
{
if(_destroyed)
{
throw new Ice.ObjectNotExistException();
}
destroyed.value = false;
java.util.List<BookDescription> l = new java.util.LinkedList<BookDescription>();
if(n <= 0)
{
return l;
}
boolean next = true;
try
{
for(int i = 0; i < n && next; ++i)
{
l.add(BookI.extractDescription(_context, _rs, current.adapter));
next = _rs.next();
}
}
catch(java.sql.SQLException e)
{
// Log the error, and raise an UnknownException.
_context.error("BookQueryResultI", e);
Ice.UnknownException ex = new Ice.UnknownException();
ex.initCause(e);
throw ex;
}
if(!next)
{
try
{
destroyed.value = true;
destroy(current);
}
catch(Exception e)
{
// Ignore.
}
}
return l;
}
synchronized public void
destroy(Ice.Current current)
{
if(_destroyed)
{
throw new Ice.ObjectNotExistException();
}
_destroyed = true;
_context.destroy(false);
current.adapter.remove(current.id);
}
// Called on application shutdown by the Library.
synchronized public void
shutdown()
{
if(!_destroyed)
{
_destroyed = true;
_context.destroy(false);
}
}
private SQLRequestContext _context;
private java.sql.ResultSet _rs;
private boolean _destroyed = false;
}
|
