|
11 | 11 | from geoscript.util.data import readFeatures |
12 | 12 | from org.geoscript.util import CollectionDelegatingFeatureSource |
13 | 13 | from org.geotools.data import FeatureSource, FeatureStore |
14 | | -from org.geotools.data import DefaultQuery, Query, Transaction |
| 14 | +from org.geotools.data import Query, Transaction |
15 | 15 | from org.geotools.factory import CommonFactoryFinder |
16 | 16 | from org.geotools.util.factory import Hints |
17 | 17 | from org.geotools.feature import FeatureCollection, FeatureCollections |
@@ -126,7 +126,7 @@ def count(self, filter=None): |
126 | 126 | """ |
127 | 127 |
|
128 | 128 | f = Filter(filter) if filter else Filter.PASS |
129 | | - count = self._source.getCount(DefaultQuery(self.name, f._filter)) |
| 129 | + count = self._source.getCount(Query(self.name, f._filter)) |
130 | 130 | if count == -1: |
131 | 131 | count = 0 |
132 | 132 | # calculate manually |
@@ -154,7 +154,7 @@ def bounds(self, filter=None): |
154 | 154 | """ |
155 | 155 |
|
156 | 156 | f = Filter(filter) if filter else Filter.PASS |
157 | | - q = DefaultQuery(self.name, f._filter) |
| 157 | + q = Query(self.name, f._filter) |
158 | 158 | e = self._source.getBounds(q) |
159 | 159 |
|
160 | 160 | if not e: |
@@ -262,7 +262,7 @@ def cursor(self, filter=None, sort=None, hints=None): |
262 | 262 | """ |
263 | 263 |
|
264 | 264 | f = Filter(filter) if filter else Filter.PASS |
265 | | - q = DefaultQuery(self.name, f._filter) |
| 265 | + q = Query(self.name, f._filter) |
266 | 266 | if sort: |
267 | 267 | sort = sort if isinstance(sort, list) else [sort] |
268 | 268 | sortBy = [] |
@@ -433,7 +433,7 @@ def reproject(self, prj, name=None, chunk=1000): |
433 | 433 | rlayer = self.workspace.create(schema=rschema) |
434 | 434 |
|
435 | 435 | # create a query specifying that feautres should be reprojected |
436 | | - q = DefaultQuery(self.name, Filter.PASS._filter) |
| 436 | + q = Query(self.name, Filter.PASS._filter) |
437 | 437 | if self.proj: |
438 | 438 | q.coordinateSystem = self.proj._crs |
439 | 439 | q.coordinateSystemReproject = prj._crs |
@@ -482,7 +482,7 @@ def filter(self, fil, name=None): |
482 | 482 | # create the filtered layer |
483 | 483 | flayer = self.workspace.create(schema=fschema) |
484 | 484 |
|
485 | | - q = DefaultQuery(self.name, f._filter) |
| 485 | + q = Query(self.name, f._filter) |
486 | 486 |
|
487 | 487 | # loop through features and add to new filtered layer |
488 | 488 | fit = self._source.getFeatures(q).features() |
|
0 commit comments