Examples of execute()


Examples of org.apache.openjpa.jdbc.sql.Union.execute()

                sel.select(mappings[i], Select.SUBS_ANY_JOINABLE, store, fetch,
                    eager);
                sel.wherePrimaryKey(sm.getObjectId(), mappings[i], store);
            }
        });
        return union.execute(this, fetch);
    }

    /**
     * Select primary key data to make sure the given instance exists, locking
     * if needed.
View Full Code Here

Examples of org.apache.openjpa.kernel.Query.execute()

        Broker broker = _factory.newBroker();
        Query q =
            broker.newQuery(JPQLParser.LANG_JPQL, "select max(a.age) FROM " +
                CacheObjectAChild1.class.getSimpleName() + " a");

        Object o = q.execute();
        assertEquals(Long.class, o.getClass());
        CacheTestHelper.assertInCache(this, q, Boolean.TRUE);

        o = q.execute();
        assertEquals(Long.class, o.getClass());
View Full Code Here

Examples of org.apache.openjpa.tools.maven.OpenJpaEnhancerMojo.execute()

     
      mojo.classes = new File( getBasedir(), "target/test-classes/" );
      mojo.compileClasspathElements = new ArrayList<String>();
      mojo.compileClasspathElements.add( mojo.classes.getAbsolutePath() );
     
      mojo.execute();
    }

}
View Full Code Here

Examples of org.apache.phoenix.compile.MutationPlan.execute()

                            // Note that the upsert select statements will need to commit any open transaction here,
                            // since they'd update data directly from coprocessors, and should thus operate on
                            // the latest state
                            try {
                                MutationPlan plan = stmt.compilePlan(PhoenixStatement.this, Sequence.ValueOp.RESERVE_SEQUENCE);
                                MutationState state = plan.execute();
                                connection.getMutationState().join(state);
                                if (connection.getAutoCommit()) {
                                    connection.commit();
                                }
                                setLastResultSet(null);
View Full Code Here

Examples of org.apache.phoenix.util.csv.CsvUpsertExecutor.execute()

            long start = System.currentTimeMillis();
            CsvUpsertListener upsertListener = new CsvUpsertListener(conn, conn.getMutateBatchSize());
            CsvUpsertExecutor csvUpsertExecutor = CsvUpsertExecutor.create(conn, tableName,
                    columnInfoList, upsertListener, arrayElementSeparator);

            csvUpsertExecutor.execute(csvParser);
            csvUpsertExecutor.close();

            conn.commit();
            double elapsedDuration = ((System.currentTimeMillis() - start) / 1000.0);
            System.out.println("CSV Upsert complete. " + upsertListener.getTotalUpsertCount()
View Full Code Here

Examples of org.apache.pivot.util.concurrent.Task.execute()

        }

        // Activate search indicator
        searchActivity.setActive(true);
        searchActivity.setVisible(true);
        task.execute(new TaskAdapter<Void>(new TaskListener<Void>() {
            public void executeFailed(Task<Void> voidTask) {
                taskExecuted(voidTask);
            }

            public void taskExecuted(Task<Void> voidTask) {
View Full Code Here

Examples of org.apache.pivot.util.concurrent.TaskGroup.execute()

        SleepTask task3 = new SleepTask(1000);
        taskGroup.add(task3);

        synchronized (taskListener) {
            taskGroup.execute(taskListener);

            try {
                taskListener.wait();
            } catch (InterruptedException exception) {
            }
View Full Code Here

Examples of org.apache.pivot.util.concurrent.TaskSequence.execute()

        SleepTask task3 = new SleepTask(1000);
        taskSequence.add(task3);

        synchronized (taskListener) {
            taskSequence.execute(taskListener);

            try {
                taskListener.wait();
            } catch (InterruptedException exception) {
            }
View Full Code Here

Examples of org.apache.pivot.web.DeleteQuery.execute()

                    );

                    activityIndicatorBoxPane.setVisible(true);
                    activityIndicator.setActive(true);

                    deleteExpenseQuery.execute(new TaskAdapter<Void>(new TaskListener<Void>() {
                        @Override
                        public void taskExecuted(Task<Void> task) {
                            activityIndicatorBoxPane.setVisible(false);
                            activityIndicator.setActive(false);
View Full Code Here

Examples of org.apache.pivot.web.GetQuery.execute()

        GetQuery getQuery = new GetQuery("feeds.dzone.com", "/javalobby/frontpage");
        getQuery.setSerializer(new XMLSerializer());
        getQuery.getParameters().put("format", "xml");

        getQuery.execute(new TaskAdapter<Object>(new TaskListener<Object>() {
            @Override
            public void taskExecuted(Task<Object> task) {
                Element root = (Element)task.getResult();
                feedListView.setListData(XMLSerializer.getElements(root, "channel", "item"));
                cardPane.setSelectedIndex(1);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.