Examples of execute()

Examples of org.apache.ojb.odmg.oql.EnhancedOQLQuery.execute()

157
158
159
160
161
162
163
164
165
166
167
            tx = _kit.getTransaction(_conn);
            _conn.invalidate(oid);
            tx.begin();
            oql.bind(new Integer(77777));
            oql.bind("336");
            it = ((Collection) oql.execute()).iterator();
            if (it.hasNext())
            {
                InterfaceArticle article = (InterfaceArticle) it.next();
                assertEquals("should be equal", 77777, article.getArticleId());
                assertEquals("should be equal", "336", article.getArticleName());
View Full Code Here

Examples of org.apache.oodt.cas.cli.action.PrintMessageAction.execute()

120
121
122
123
124
125
126
127
128
129
      AdvancedCmdLineOption printHelloWorldOption = (AdvancedCmdLineOption) getOptionByName(
            "printHelloWorld", options);
      printHelloWorldOption.getHandler().handleOption(printHelloWorldAction,
            createOptionInstance(printHelloWorldOption));
      ActionMessagePrinter printer = new ActionMessagePrinter();
      printHelloWorldAction.execute(printer);
      assertEquals(1, printer.getPrintedMessages().size());
      assertEquals("Hello World!", printer.getPrintedMessages().get(0));
   }
}
View Full Code Here

Examples of org.apache.oodt.cas.pushpull.expressions.Method.execute()

179
180
181
182
183
184
185
186
187
188
189
                                        + j), "#\", ()");
                        while (st.hasMoreTokens()) {
                            String arg = st.nextToken();
                            m.addArg(null, arg);
                        }
                        String returnValue = m.execute().toString();
                        input = input.substring(0, i)
                                + returnValue
                                + input.substring(input.substring(i).indexOf(
                                        ")")
                                        + 1 + i);
View Full Code Here

Examples of org.apache.oodt.commons.database.SqlScript.execute()

87
88
89
90
91
92
93
94
95
96
97
     */
    protected void setUp() throws Exception {
        ds = DatabaseConnectionBuilder.buildDataSource("sa", "", "org.hsqldb.jdbcDriver", "jdbc:hsqldb:file:" + tmpDirPath + "/testCat;shutdown=true");
        SqlScript coreSchemaScript = new SqlScript("src/testdata/workflow.sql", ds);
        coreSchemaScript.loadScript();
        coreSchemaScript.execute();
        ds.getConnection().commit();
    }

    /*
     * (non-Javadoc)
 
View Full Code Here

Examples of org.apache.oozie.action.hadoop.FileSystemActions.execute()

56
57
58
59
60
61
62
63
64
65
66
                commandType = ..........;
                */
                // As of now, the available prepare action is of type hdfs. Hence, assigning the value directly
                commandType = "hdfs";
                if (commandType.equalsIgnoreCase("hdfs")) {
                    fsActions.execute(nl.item(i));
                } /*else if(commandType.equalsIgnoreCase("hcat")) {     //Other command types go here
                    hCatActions.execute(nl.item(i));
                  }*/
            }
        } catch (IOException ioe) {
View Full Code Here

Examples of org.apache.oozie.service.JPAService.execute()

192
193
194
195
196
197
198
199
200
201
202
        WorkflowJobBean job = this.addRecordToWfJobTable(WorkflowJob.Status.RUNNING, WorkflowInstance.Status.RUNNING);
        WorkflowActionBean action = this.addRecordToWfActionTable(job.getId(), "1", WorkflowAction.Status.PREP);
        WorkflowActionGetJPAExecutor wfActionGetCmd = new WorkflowActionGetJPAExecutor(action.getId());

        new ActionStartXCommand(action.getId(), "map-reduce").call();
        action = jpaService.execute(wfActionGetCmd);

        ActionExecutorContext context = new ActionXCommand.ActionExecutorContext(job, action, false, false);
        MapReduceActionExecutor actionExecutor = new MapReduceActionExecutor();
        JobConf conf = actionExecutor.createBaseHadoopConf(context, XmlUtils.parseXml(action.getConf()));
        String user = conf.get("user.name");
View Full Code Here

Examples of org.apache.openejb.quartz.Job.execute()

316
317
318
319
320
321
322
323
324
325
326
                }

                endpoint = (MessageEndpoint) job;
                endpoint.beforeDelivery(method);

                job.execute(execution);

            } catch (final NoSuchMethodException e) {
                throw new IllegalStateException(e);
            } catch (final ResourceException e) {
                ex = new JobExecutionException(e);
View Full Code Here

Examples of org.apache.openejb.server.cli.command.AbstractCommand.execute()

226
227
228
229
230
231
232
233
234
235
236
                    recipe.allow(Option.IGNORE_MISSING_PROPERTIES);
                    recipe.allow(Option.NAMED_PARAMETERS);

                    try {
                        final AbstractCommand cmdInstance = (AbstractCommand) recipe.create();
                        cmdInstance.execute(line);
                    } catch (Exception e) {
                        streamManager.writeErr(e);
                    }
                } else {
                    streamManager.writeErr("sorry i don't understand '" + line + "'");
View Full Code Here

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

371
372
373
374
375
376
377
378
379
380
381
        if (!select(sel, mapping, subs, sm, null, fetch,
            JDBCFetchConfiguration.EAGER_JOIN, true, false))
            return null;
        sel.wherePrimaryKey(sm.getObjectId(), mapping, this);
        sel.setExpectedResultCount(1, false);
        return sel.execute(this, fetch);
    }

    /**
     * Select a union of the data for the given instance from possible concrete
     * mappings and return the result.
View Full Code Here

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

375
376
377
378
379
380
381
382
383
384
385
                esel = sel;

            // get result
            fms[i].selectEagerParallel(esel, null, store, fetch,
                JDBCFetchConfiguration.EAGER_PARALLEL);
            res = esel.execute(store, fetch);
            try {
                // and load result into paged instances
                for (int j = start; j < end && _page[j] != null; j++)
                    res = fms[i].loadEagerParallel(ctx.getStateManager
                        (_page[j]), store, fetch, res);
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.