blob: a3a159a48e4c12e827cf75715ca025e2a3f1223f (
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
98
99
100
101
102
103
104
105
106
107
108
109
|
// **********************************************************************
//
// 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 java.sql.Connection object until
// destroyed.
BookQueryResultI(Ice.Logger logger, SQLRequestContext context, java.sql.ResultSet rs)
{
_logger = logger;
_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.
error(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();
current.adapter.remove(current.id);
}
// Called on application shutdown by the Library.
synchronized public void
shutdown()
{
if(!_destroyed)
{
_destroyed = true;
_context.destroy();
}
}
private void
error(Exception ex)
{
java.io.StringWriter sw = new java.io.StringWriter();
java.io.PrintWriter pw = new java.io.PrintWriter(sw);
ex.printStackTrace(pw);
pw.flush();
_logger.error("BookQueryResultI: error:\n" + sw.toString());
}
private Ice.Logger _logger;
private SQLRequestContext _context;
private java.sql.ResultSet _rs;
private boolean _destroyed = false;
}
|
