Examples of org.geotools.data.DefaultTransaction

org.geotools.data.DefaultTransaction
Quick implementation of Transaction api.
Please see Transaction interface for an outline of what this class is all about.
@author Jody Garnett, Refractions Research @source $URL$

        assertTrue("visitor completed", progress.completed);
        assertEquals("visitor 100%", 100f, progress.progress);
        assertNull("visitor no problems", progress.exception);


        // we are going to use this transaction to modify and commit
        DefaultTransaction t1 = new DefaultTransaction("Transaction 1");
        SimpleFeatureStore featureStore1 = (SimpleFeatureStore) dataStore
                .getFeatureSource(typeName);
        featureStore1.setTransaction(t1);
        TestFeatureListener listener1 = new TestFeatureListener();
        featureStore1.addFeatureListener(listener1);
        // we are going to use this transaction to modify and rollback
        DefaultTransaction t2 = new DefaultTransaction("Transaction 2");
        SimpleFeatureStore featureStore2 = (SimpleFeatureStore) dataStore
                .getFeatureSource(typeName);
        featureStore2.setTransaction(t2);
        TestFeatureListener listener2 = new TestFeatureListener();
        featureStore2.addFeatureListener(listener2);

View Full Code Here

        // public Transaction.AUTO_COMMIT view of the world
        // is as expected.
        assertEquals(8, origional.getCount(Query.ALL));


        // we are going to use this transaction to modify and commit
        DefaultTransaction t1 = new DefaultTransaction("Transaction 1");
        SimpleFeatureStore featureStore1 = (SimpleFeatureStore) dataStore
                .getFeatureSource(typeName);
        featureStore1.setTransaction(t1);
        TestFeatureListener listener1 = new TestFeatureListener();
        featureStore1.addFeatureListener(listener1);


        // verify they are all working
        assertEquals(8, origional.getCount(Query.ALL));
        assertEquals(8, featureStore1.getCount(Query.ALL));


        SimpleFeatureType schema = origional.getSchema();
        SimpleFeatureBuilder build = new SimpleFeatureBuilder(schema);


        int value = 24;
        build.add(Integer.valueOf(value));
        build.add(Short.valueOf((short) value));
        build.add(new Float(value / 10.0F));
        build.add(new Double(value / 10D));
        build.add("FEATURE_" + value);


        Calendar cal = Calendar.getInstance();
        cal.set(2004, 06, value, 0, 0, 0);
        build.add(cal);


        WKTReader reader = new WKTReader();
        build.add(reader.read("POINT(1 1)"));


        SimpleFeature newFeature = build.buildFeature(null);
        SimpleFeatureCollection newFeatures = DataUtilities.collection(newFeature);


        List<FeatureId> newFids = featureStore1.addFeatures(newFeatures);
        assertEquals(0, listener.list.size());
        assertEquals(1, listener1.list.size());


        FeatureEvent e = listener1.list.get(0);
        Id id = (Id) e.getFilter();
        assertTrue(id.getIdentifiers().containsAll(newFids));
        // remember the FeatureId with a strong reference
        FeatureId tempFeatureId = (FeatureId) id.getIdentifiers().iterator().next();
        assertTrue(newFids.contains(tempFeatureId));


        t1.commit();
        assertEquals(1, listener.list.size());
        assertEquals(2, listener1.list.size());


        BatchFeatureEvent batch = (BatchFeatureEvent) listener1.list.get(2);
        assertFalse("confirm tempFid is not in the commit",

View Full Code Here

        final DataStore ds = testData.getDataStore();


        final SimpleFeatureType ftype = testFeatures.getSchema();
        final SimpleFeatureIterator iterator = testFeatures.features();


        final Transaction transaction = new DefaultTransaction();
        final FeatureWriter<SimpleFeatureType, SimpleFeature> writer;
        writer = ds.getFeatureWriter(typeName, transaction);


        FeatureReader<SimpleFeatureType, SimpleFeature> reader;
        final Query query = new Query(typeName);
        try {
            try {
                while (iterator.hasNext()) {
                    SimpleFeature addFeature = iterator.next();
                    SimpleFeature newFeature = writer.next();
                    for (int i = 0; i < ftype.getAttributeCount(); i++) {
                        String localName = ftype.getDescriptor(i).getLocalName();
                        newFeature.setAttribute(localName, addFeature.getAttribute(localName));
                    }
                    writer.write();
                }
            } catch (Exception e) {
                transaction.rollback();
                transaction.close();
            } finally {
                writer.close();
            }


            reader = ds.getFeatureReader(query, Transaction.AUTO_COMMIT);
            boolean hasNext;
            try {
                hasNext = reader.hasNext();
            } finally {
                reader.close();
            }
            if (databaseIsMsSqlServer) {
                // SQL Server always is at READ UNCOMMITTED isolation level...
                assertTrue(hasNext);
            } else {
                assertFalse("Features added, transaction not commited", hasNext);
            }


            try {
                transaction.commit();
            } catch (Exception e) {
                transaction.rollback();
                throw e;
            }
        } finally {
            transaction.close();
        }


        try {
            reader = ds.getFeatureReader(query, Transaction.AUTO_COMMIT);
            for (int i = 0; i < featureCount; i++) {

View Full Code Here

        testMultiVersionSupport(Transaction.AUTO_COMMIT);
    }


    @Test
    public void testMultiVersionSupportTransaction() throws IOException {
        DefaultTransaction transaction = new DefaultTransaction();
        testMultiVersionSupport(transaction);
    }

View Full Code Here


    @Test
    public void testFeatureWriter_RowIDSDE_Transaction() throws IOException,
            UnavailableConnectionException {
        final String tableName = seRowidSdeTable;
        final Transaction transaction = new DefaultTransaction();
        try {
            FeatureWriter<SimpleFeatureType, SimpleFeature> writer;


            writer = addFeatures(tableName, transaction);
            /*
             * This one works regardless of the database being MSSQL or not because the table IS
             * being created as versioned by testData.createTestTable.
             * <http://support.esri.com/index.cfm?fa=knowledgebase.techarticles.articleShow&d=32190>
             */
            assertEquals(0, ds.getFeatureSource(tableName).getCount(Query.ALL));
            transaction.commit();
            writer.close();
            assertEquals(2, ds.getFeatureSource(tableName).getCount(Query.ALL));
        } finally {
            transaction.close();
        }
    }

View Full Code Here


    @Test
    public void testFeatureWriter_RowID_USER_Transaction() throws IOException,
            UnavailableConnectionException {
        final String tableName = seRowidUserTable;
        final Transaction transaction = new DefaultTransaction();
        try {
            FeatureWriter<SimpleFeatureType, SimpleFeature> writer;


            writer = addFeatures(tableName, transaction);
            if (databaseIsMsSqlServer) {
                /*
                 * SQL Server always is at READ UNCOMMITTED isolation level iff the table is not
                 * versioned. And this one can't be versioned cause it has no sde maintained row id
                 * <
                 * http://support.esri.com/index.cfm?fa=knowledgebase.techarticles.articleShow&d=32190
                 * >
                 */
                assertEquals(2, ds.getFeatureSource(tableName).getCount(Query.ALL));
            } else {
                assertEquals(0, ds.getFeatureSource(tableName).getCount(Query.ALL));
            }
            transaction.commit();
            writer.close();
            assertEquals(2, ds.getFeatureSource(tableName).getCount(Query.ALL));
        } finally {
            transaction.close();
        }
    }

View Full Code Here

    @Test
    public void testFetureStore_ROWID_SDE_Transaction() throws IOException,
            UnavailableConnectionException {
        String tableName = seRowidSdeTable;


        Transaction transaction = new DefaultTransaction();
        try {
            List<FeatureId> fids = testFeatureStore(tableName, transaction);
            assertEquals(1, fids.size());


            assertEquals(0, ds.getFeatureSource(tableName).getCount(Query.ALL));
            transaction.commit();
            assertEquals(1, ds.getFeatureSource(tableName).getCount(Query.ALL));
        } finally {
            transaction.close();
        }
    }

View Full Code Here

    @Test
    public void testFetureStore_ROWID_USER_Transaction() throws IOException,
            UnavailableConnectionException {
        String tableName = seRowidUserTable;


        Transaction transaction = new DefaultTransaction();
        try {
            List<FeatureId> fids = testFeatureStore(tableName, transaction);
            assertEquals(1, fids.size());


            if (databaseIsMsSqlServer) {
                /*
                 * SQL Server always is at READ UNCOMMITTED isolation level iff the table is not
                 * versioned. And this one can't be versioned cause it has no sde maintained row id
                 * <
                 * http://support.esri.com/index.cfm?fa=knowledgebase.techarticles.articleShow&d=32190
                 * >
                 */
                assertEquals(1, ds.getFeatureSource(tableName).getCount(Query.ALL));
            } else {
                assertEquals(0, ds.getFeatureSource(tableName).getCount(Query.ALL));
            }
            transaction.commit();
            assertEquals(1, ds.getFeatureSource(tableName).getCount(Query.ALL));
        } finally {
            transaction.close();
        }
    }

View Full Code Here

        testFeatures = testData.createTestFeatures(LineString.class, featureCount);


        final DataStore ds = testData.getDataStore();
        final SimpleFeatureStore fStore;
        fStore = (SimpleFeatureStore) ds.getFeatureSource(typeName);
        final Transaction transaction = new DefaultTransaction("testInsertTransactionAndQueryByFid");
        fStore.setTransaction(transaction);
        try {
            final List<FeatureId> addedFids = fStore.addFeatures(testFeatures);
            final FilterFactory ff = CommonFactoryFinder.getFilterFactory(null);


            final Set<FeatureId> fids = new HashSet<FeatureId>();
            for (FeatureId fid : addedFids) {
                fids.add(fid);
            }
            final Id newFidsFilter = ff.id(fids);


            SimpleFeatureCollection features;
            features = fStore.getFeatures(newFidsFilter);
            assertEquals(2, features.size());
            transaction.commit();
        } catch (Exception e) {
            transaction.rollback();
            throw e;
        } finally {
            transaction.close();
        }
    }

View Full Code Here

        final Filter oldValueFilter = CQL.toFilter("INT32_COL = 3");
        final Query oldValueQuery = new Query(typeName, oldValueFilter);
        final Filter newValueFilter = CQL.toFilter("INT32_COL = -1000");
        final Query newValueQuery = new Query(typeName, newValueFilter);


        final Transaction transaction = new DefaultTransaction("testUpdateTransaction");
        FeatureWriter<SimpleFeatureType, SimpleFeature> writer;
        writer = ds.getFeatureWriter(typeName, oldValueFilter, transaction);


        FeatureReader<SimpleFeatureType, SimpleFeature> reader;


        try {
            try {
                assertTrue(writer.hasNext());
                SimpleFeature feature = writer.next();
                feature.setAttribute("INT32_COL", Integer.valueOf(-1000));
                writer.write();
                assertFalse(writer.hasNext());
            } finally {
                writer.close();
            }


            reader = ds.getFeatureReader(oldValueQuery, Transaction.AUTO_COMMIT);
            try {
                if (databaseIsMsSqlServer) {
                    // SQL Server always is at READ UNCOMMITTED isolation level...
                    assertFalse(reader.hasNext());
                } else {
                    assertTrue(reader.hasNext());
                }
            } finally {
                reader.close();
            }


            reader = ds.getFeatureReader(newValueQuery, Transaction.AUTO_COMMIT);
            try {
                if (databaseIsMsSqlServer) {
                    // SQL Server always is at READ UNCOMMITTED isolation level...
                    assertTrue(reader.hasNext());
                } else {
                    assertFalse(reader.hasNext());
                }
            } finally {
                reader.close();
            }


            reader = ds.getFeatureReader(oldValueQuery, transaction);
            try {
                assertFalse(reader.hasNext());
            } finally {
                reader.close();
            }


            reader = ds.getFeatureReader(newValueQuery, transaction);
            try {
                assertTrue(reader.hasNext());
            } finally {
                reader.close();
            }


            try {
                transaction.commit();
            } catch (IOException e) {
                transaction.rollback();
                throw e;
            }
        } finally {
            transaction.close();
        }


        reader = ds.getFeatureReader(newValueQuery, Transaction.AUTO_COMMIT);
        try {
            assertTrue(reader.hasNext());

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of org.geotools.data.DefaultTransaction

edu.isi.karma.geospatial.WorksheetToFeatureCollection

it.geosolutions.geobatch.unredd.script.util.PostGISUtils

jobs.ProcessGisExport

mil.nga.giat.geowave.vector.plugin.GeoWaveFeatureSourceTest

mil.nga.giat.geowave.vector.plugin.lock.MemoryLockManagerTest

mil.nga.giat.geowave.vector.plugin.WFSBoundedQueryTest

mil.nga.giat.geowave.vector.plugin.WFSSpatialTest

mil.nga.giat.geowave.vector.plugin.WFSTransactionTest

org.catais.veriso.interlis.IliReader

org.fao.geonet.kernel.search.SearchManager$Spatial

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.