blob: 71b535975643bb2b4bece69c4723d1c23f349525 (
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
|
// **********************************************************************
//
// Copyright (c) 2003-2012 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
{
BookQueryResultI(SQLRequestContext context, java.sql.ResultSet rs, Ice.ObjectAdapter adapter) throws java.sql.SQLException
{
_books = new java.util.Stack<BookDescription>();
for(int i = 0; i < MAX_BOOK_QUERY_RESULT; ++i)
{
_books.add(BookI.extractDescription(context, rs, adapter));
if(!rs.next())
{
break;
}
}
}
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;
}
for(int i = 0; i < n && _books.size() > 0; ++i)
{
l.add(_books.pop());
}
if(_books.size() <= 0)
{
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;
current.adapter.remove(current.id);
}
// Called on application shutdown by the Library.
synchronized public void
shutdown()
{
if(!_destroyed)
{
_destroyed = true;
}
}
private java.util.Stack<BookDescription> _books;
private boolean _destroyed = false;
private static final int MAX_BOOK_QUERY_RESULT = 1000;
}
|
