Revision 46032
trunk/org.gvsig.desktop/org.gvsig.desktop.compat.cdc/org.gvsig.fmap.dal/org.gvsig.fmap.dal.db/org.gvsig.fmap.dal.db.jdbc/src/main/java/org/gvsig/fmap/dal/store/jdbc2/spi/JDBCStoreProviderBase.java | ||
---|---|---|
593 | 593 |
return true; |
594 | 594 |
} |
595 | 595 |
|
596 |
protected AppendOperation getAppendOperation() throws DataException { |
|
597 |
if( this.appendOperation == null ) { |
|
598 |
FeatureType type = this.getFeatureStore().getDefaultFeatureType(); |
|
599 |
JDBCStoreParameters params = this.getParameters(); |
|
600 |
this.appendOperation = this.getOperations().createAppend( |
|
596 |
protected AppendOperation createAppendOperation() throws DataException { |
|
597 |
FeatureType type = this.getFeatureStore().getDefaultFeatureType(); |
|
598 |
JDBCStoreParameters params = this.getParameters(); |
|
599 |
AppendOperation theAppendOperation = this.getOperations().createAppend( |
|
601 | 600 |
this.getOperations().createTableReference(params), |
602 | 601 |
type |
603 |
); |
|
604 |
} |
|
605 |
return this.appendOperation; |
|
602 |
); |
|
603 |
return theAppendOperation; |
|
606 | 604 |
} |
607 | 605 |
|
608 | 606 |
@Override |
609 | 607 |
public void endAppend() throws DataException { |
610 |
this.getAppendOperation().end();
|
|
608 |
this.appendOperation.end();
|
|
611 | 609 |
} |
612 | 610 |
|
613 | 611 |
@Override |
614 | 612 |
public void abortAppend() throws DataException { |
615 |
this.getAppendOperation().abort();
|
|
613 |
this.appendOperation.abort();
|
|
616 | 614 |
} |
617 | 615 |
|
618 | 616 |
@Override |
619 | 617 |
public void beginAppend() throws DataException { |
620 |
this.getAppendOperation().begin(); |
|
618 |
if( this.appendOperation == null ) { |
|
619 |
this.appendOperation = createAppendOperation(); |
|
620 |
} |
|
621 |
this.appendOperation.begin(); |
|
621 | 622 |
} |
622 | 623 |
|
623 | 624 |
@Override |
624 | 625 |
public void append(final FeatureProvider featureProvider) throws DataException { |
625 |
this.getAppendOperation().append(featureProvider);
|
|
626 |
this.appendOperation.append(featureProvider);
|
|
626 | 627 |
} |
627 | 628 |
|
628 | 629 |
@Override |
... | ... | |
714 | 715 |
return super.toString(); |
715 | 716 |
} |
716 | 717 |
} |
718 |
|
|
719 |
@Override |
|
720 |
public void refresh() throws OpenException { |
|
721 |
// // Force to recalculare count, envelope and allowWrite |
|
722 |
// this.count = null; |
|
723 |
// this.envelope = null; |
|
724 |
// this.allowWrite = null; |
|
725 |
// |
|
726 |
// if( this.helper.getResulSetControler().getOpenCount()>0 ) { |
|
727 |
// // Has ResultSetEntry open. Oh!!!! |
|
728 |
// this.helper.getResulSetControler().closeAll(); |
|
729 |
// } |
|
730 |
// if( this.appendOperation!=null ) { |
|
731 |
// // Has and append operation in progress, Oh!! |
|
732 |
// this.appendOperation.abort(); |
|
733 |
// this.appendOperation = null; |
|
734 |
// } |
|
735 |
super.refresh(); |
|
736 |
} |
|
717 | 737 |
|
718 |
|
|
719 | 738 |
} |
Also available in: Unified diff