Revision 20058 trunk/libraries/libDataSourceDBBaseDrivers/src/org/gvsig/data/datastores/vectorial/db/jdbc/postgresql/PostgresqlFeatureCollectionEditingFiltered.java
PostgresqlFeatureCollectionEditingFiltered.java | ||
---|---|---|
114 | 114 |
protected class PostgresIterator implements Iterator{ |
115 | 115 |
private Iterator dbIter; |
116 | 116 |
private Iterator mIter; |
117 |
public PostgresIterator(JDBCStore store,DBFeatureType featureType,String sql, int fetchSize,FeatureManager featureManager) throws ReadException{
|
|
117 |
public PostgresIterator(PostgresqlStore store,DBFeatureType featureType,String sql, int fetchSize,FeatureManager featureManager) throws ReadException{
|
|
118 | 118 |
this.dbIter = new IteratorDB(store,featureType,sql,fetchSize,featureManager); |
119 | 119 |
this.mIter = new IteratorMemory(featureType,featureManager); |
120 | 120 |
} |
... | ... | |
139 | 139 |
private boolean nextChecked=false; |
140 | 140 |
private IFeature feature; |
141 | 141 |
private ResultSet rs; |
142 |
private JDBCStore store;
|
|
142 |
private PostgresqlStore store;
|
|
143 | 143 |
private DBFeatureType featureType; |
144 | 144 |
private boolean rsEOF=false; |
145 | 145 |
private FeatureManager featureManager; |
... | ... | |
149 | 149 |
private int index; |
150 | 150 |
|
151 | 151 |
|
152 |
public IteratorDB(JDBCStore store, DBFeatureType featureType,String sql,int fetchSize, FeatureManager featureManager) throws ReadException{
|
|
152 |
public IteratorDB(PostgresqlStore store, DBFeatureType featureType,String sql,int fetchSize, FeatureManager featureManager) throws ReadException{
|
|
153 | 153 |
this.store = store; |
154 | 154 |
this.featureType = featureType; |
155 | 155 |
this.featureManager= featureManager; |
... | ... | |
230 | 230 |
IFeature feature=null; |
231 | 231 |
try { |
232 | 232 |
if(rs.next()){ |
233 |
feature=PostgresqlStoreUtils.createFeature(this.store, this.rs, featureType);
|
|
233 |
feature=this.store.createFeatureFromResulset(this.rs, featureType);
|
|
234 | 234 |
} |
235 | 235 |
} catch (java.sql.SQLException e) { |
236 | 236 |
throw new RuntimeException( |
Also available in: Unified diff