Revision 20976 branches/v10/extensions/extArcims/src/es/prodevelop/cit/gvsig/arcims/fmap/drivers/ArcImsAttributesDataSourceAdapter.java
| ArcImsAttributesDataSourceAdapter.java | ||
|---|---|---|
| 156 | 156 |
|
| 157 | 157 |
logger.info("Stored " + ids.length + " IDs");
|
| 158 | 158 |
setRowsPerRequest(); |
| 159 |
|
|
| 160 |
// String idcolname = dataDriver.executeCreateTableWithFieldsAndTypes(tableName, col_Names, col_Types); |
|
| 161 |
// dataDriver.executeSetEmptyRowsWithIds(tableName, ids, idcolname); |
|
| 162 |
// System.err.println("dataDriver.getFieldValue(0, 0) = " + dataDriver.getFieldValue(0, 0).getStringValue(dataDriver.internalValueWriter));
|
|
| 163 |
// getRowId(5); |
|
| 164 |
// stop(); |
|
| 165 |
// logger.debug("Done: dataDriver.close();");
|
|
| 166 | 159 |
} |
| 167 | 160 |
catch (Exception e) {
|
| 168 | 161 |
logger.error("While creating in-memory database ", e);
|
| ... | ... | |
| 173 | 166 |
// DriverException de = new DriverException("cannot_delete");
|
| 174 | 167 |
logger.warn("So far, you cannot delete ");
|
| 175 | 168 |
|
| 176 |
// throw de; |
|
| 177 |
// // dataDriver.setRequested((int) rowInd, false); |
|
| 178 |
// start(); |
|
| 179 |
// dataDriver.deleteRow(dsFactory, (int) rowInd); |
|
| 180 |
// stop(); |
|
| 181 |
// // dataDriver.deleteRow(dsFactory, (int) rowInd); |
|
| 182 | 169 |
} |
| 183 | 170 |
|
| 184 | 171 |
public void insertFilledRowAt(long index, Value[] values) |
| ... | ... | |
| 216 | 203 |
} |
| 217 | 204 |
|
| 218 | 205 |
public void start() throws DriverException {
|
| 219 |
// try {
|
|
| 220 |
// // dataDriver.open("");
|
|
| 221 |
// dataDriver.open("select * from " + tableName);
|
|
| 222 |
// } catch (SQLException e) {
|
|
| 223 |
// DriverException de = new DriverException(e.getMessage()); |
|
| 224 |
// logger.error("While starting datasource ", e);
|
|
| 225 |
// throw de; |
|
| 226 |
// } |
|
| 227 |
// // logger.debug("start()");
|
|
| 228 |
// // dataDriver.open("");
|
|
| 229 | 206 |
} |
| 230 | 207 |
|
| 231 | 208 |
public void stop() throws DriverException {
|
| 232 |
// try {
|
|
| 233 |
// dataDriver.close(); |
|
| 234 |
// } catch (SQLException e) {
|
|
| 235 |
// DriverException de = new DriverException(e.getMessage()); |
|
| 236 |
// throw de; |
|
| 237 |
// } |
|
| 238 | 209 |
} |
| 239 | 210 |
|
| 240 | 211 |
public String getName() {
|
| ... | ... | |
| 425 | 396 |
if (dataDriver.isNonRequestedRow((int) row)) {
|
| 426 | 397 |
int[] lim = getBlockLimits((int) row); |
| 427 | 398 |
|
| 428 |
System.err.println("Se ha pedido fila no disponible: " + row);
|
|
| 429 |
System.err.println("Limites: [ " + lim[0] + " , " + lim[1] + " ]");
|
|
| 399 |
logger.debug("Se ha pedido fila no disponible: " + row);
|
|
| 400 |
logger.debug("Limites: [ " + lim[0] + " , " + lim[1] + " ]");
|
|
| 430 | 401 |
|
| 431 | 402 |
// FBitSet fbs = dataDriver.getThisAndNonRequestedUpTo((int) row, rowsPerRequest); |
| 432 | 403 |
try {
|
| ... | ... | |
| 519 | 490 |
// int resp = |
| 520 | 491 |
dataDriver.updateRow(new_row, fld_query, rowind); |
| 521 | 492 |
|
| 522 |
// if (! ((new_row.length == fld_query.length) |
|
| 523 |
// || ((new_row.length == getFieldCount()) && (fld_query[0].compareTo("#ALL#") == 0)))) {
|
|
| 524 |
// DriverException de = new DriverException("array_error");
|
|
| 525 |
// logger.error("Wrong array sizes while updating row ", de);
|
|
| 526 |
// throw de; |
|
| 527 |
// } |
|
| 528 |
// |
|
| 529 |
// if (new_row.length == 0) {
|
|
| 530 |
// DriverException de = new DriverException("array_error");
|
|
| 531 |
// logger.error("Wrong array sizes while updating row ", de);
|
|
| 532 |
// throw de; |
|
| 533 |
// } |
|
| 534 |
// |
|
| 535 |
// if (fld_query[0].compareTo("#ALL#") == 0) {
|
|
| 536 |
// int length = getFieldCount(); |
|
| 537 |
// String newfldquery[] = new String[length]; |
|
| 538 |
// for (int i=0; i<length; i++) {
|
|
| 539 |
// newfldquery[i] = getFieldName(i); |
|
| 540 |
// } |
|
| 541 |
// return attsData.updateRow(new_row, newfldquery); |
|
| 542 |
// } |
|
| 543 |
// |
|
| 544 |
// return attsData.updateRow(new_row, fld_query); |
|
| 545 | 493 |
} |
| 546 | 494 |
|
| 547 | 495 |
public String getIdColName() throws DriverException {
|
| ... | ... | |
| 570 | 518 |
|
| 571 | 519 |
return resp; |
| 572 | 520 |
|
| 573 |
// System.out.println("dataDriver.getRowId(dsFactory, " + row + ") = " + dataDriver.getRowId(dsFactory, row));
|
|
| 574 |
// return 0; |
|
| 575 |
// return dataDriver.getRowId(row); |
|
| 576 |
// int resp = -1; |
|
| 577 |
// try {
|
|
| 578 |
// resp = attsData.getRowId(row); |
|
| 579 |
// } catch (DriverException e) {
|
|
| 580 |
// logger.error("While getting row ID ", e);
|
|
| 581 |
// } |
|
| 582 |
// return resp; |
|
| 583 | 521 |
} |
| 584 | 522 |
|
| 585 | 523 |
public int getRowIndex(int id) throws DriverException {
|
Also available in: Unified diff