00001
package com.quadcap.sql;
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00032
00033
00034
00035
00036
00037
00038
00039
00040
00041
import java.io.Externalizable;
00042
import java.io.IOException;
00043
import java.io.ObjectInput;
00044
import java.io.ObjectOutput;
00045
00046
import java.util.Vector;
00047
00048
import java.sql.SQLException;
00049
00050
import com.quadcap.sql.types.Value;
00051
import com.quadcap.sql.types.ValueNull;
00052
00053
import com.quadcap.util.Debug;
00054
00055
00056
00057
00058
00059
00060
00061 public class ItemsRow extends Row {
00062 Session session;
00063 Vector
items;
00064 Cursor cursor;
00065 Row myRow;
00066 Row baseRow;
00067 int[]
map;
00068
00069 public ItemsRow(
Session session, Vector items,
Cursor cursor,
00070
Row r,
int[] map)
throws SQLException {
00071
this.session =
session;
00072
this.items =
items;
00073
this.cursor =
cursor;
00074
this.map =
map;
00075
this.myRow =
new Row(
items.size());
00076
if (r == null &&
cursor != null) {
00077 r =
new Row(
cursor.
getColumnCount());
00078
for (
int i = 1; i <= r.size(); i++) r.set(i,
ValueNull.valueNull);
00079 }
00080
this.nextRow(r);
00081 }
00082
00083 Row getBaseRow() {
return baseRow; }
00084
00085 public void nextRow(
Row r)
throws SQLException {
00086
this.baseRow = r;
00087
for (
int i = 1; i <=
size(); i++) {
00088
myRow.
set(i,
getItem(r, i));
00089 }
00090 }
00091
00092 public int size() {
return map.length; }
00093
00094 public Value item(
int i)
throws SQLException {
00095
return myRow.
item(i);
00096 }
00097
00098 public Value getItem(
Row r,
int i)
throws SQLException {
00099
int pos =
map[i-1];
00100
if (pos < 0) {
00101
SelectItem item = (
SelectItem)
items.elementAt(i-1);
00102
Expression e = item.
getExpression();
00103
return e.
getValue(
session,
cursor);
00104 }
else if (r != null) {
00105
return r.item(pos);
00106 }
else {
00107
return new ValueNull();
00108 }
00109 }
00110
00111 public void set(
int i,
Value val)
throws SQLException {
00112
int pos =
map[i-1];
00113
if (pos < 0) {
00114
throw new SQLException(
"Not updatable: " +
00115
items.elementAt(i-1),
00116
"42000");
00117 }
00118
myRow.
set(i, val);
00119
baseRow.
set(map[i-1], val);
00120 }
00121
00122 public boolean isUpdateable(
int i) {
00123
return map[i-1] >= 0;
00124 }
00125 }