org.teiid.metadata.Table.getInsertPlan()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(5.0k)|赞(0)|评价(0)|浏览(99)

本文整理了Java中org.teiid.metadata.Table.getInsertPlan()方法的一些代码示例,展示了Table.getInsertPlan()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Table.getInsertPlan()方法的具体详情如下:
包路径:org.teiid.metadata.Table
类名称:Table
方法名:getInsertPlan

Table.getInsertPlan介绍

暂无

代码示例

代码示例来源:origin: org.jboss.teiid/teiid-engine

private static String getPlanForEvent(Table t, TriggerEvent event) {
  switch (event) {
  case DELETE:
    return t.getDeletePlan();
  case INSERT:
    return t.getInsertPlan();
  case UPDATE:
    return t.getUpdatePlan();
  }
  throw new AssertionError();
}

代码示例来源:origin: org.teiid/teiid-engine

private static String getPlanForEvent(Table t, TriggerEvent event) {
  switch (event) {
  case DELETE:
    return t.getDeletePlan();
  case INSERT:
    return t.getInsertPlan();
  case UPDATE:
    return t.getUpdatePlan();
  }
  throw new AssertionError();
}

代码示例来源:origin: teiid/teiid

private static String getPlanForEvent(Table t, TriggerEvent event) {
  switch (event) {
  case DELETE:
    return t.getDeletePlan();
  case INSERT:
    return t.getInsertPlan();
  case UPDATE:
    return t.getUpdatePlan();
  }
  throw new AssertionError();
}

代码示例来源:origin: org.jboss.teiid/teiid-engine

public String getInsertPlan(final Object groupID) throws TeiidComponentException, QueryMetadataException {
  Table tableRecordImpl = (Table)groupID;
  if (!tableRecordImpl.isVirtual()) {
     throw new QueryMetadataException(QueryPlugin.Event.TEIID30359, QueryPlugin.Util.gs(QueryPlugin.Event.TEIID30359, tableRecordImpl.getFullName(), "Insert")); //$NON-NLS-1$
  }
  return tableRecordImpl.isInsertPlanEnabled()?tableRecordImpl.getInsertPlan():null;
}

代码示例来源:origin: org.teiid/teiid-engine

public String getInsertPlan(final Object groupID) throws TeiidComponentException, QueryMetadataException {
  Table tableRecordImpl = (Table)groupID;
  if (!tableRecordImpl.isVirtual()) {
     throw new QueryMetadataException(QueryPlugin.Event.TEIID30359, QueryPlugin.Util.gs(QueryPlugin.Event.TEIID30359, tableRecordImpl.getFullName(), "Insert")); //$NON-NLS-1$
  }
  return tableRecordImpl.isInsertPlanEnabled()?tableRecordImpl.getInsertPlan():null;
}

代码示例来源:origin: teiid/teiid

public String getInsertPlan(final Object groupID) throws TeiidComponentException, QueryMetadataException {
  Table tableRecordImpl = (Table)groupID;
  if (!tableRecordImpl.isVirtual()) {
     throw new QueryMetadataException(QueryPlugin.Event.TEIID30359, QueryPlugin.Util.gs(QueryPlugin.Event.TEIID30359, tableRecordImpl.getFullName(), "Insert")); //$NON-NLS-1$
  }
  return tableRecordImpl.isInsertPlanEnabled()?tableRecordImpl.getInsertPlan():null;
}

代码示例来源:origin: teiid/teiid

@Test
public void testInsteadOfTrigger() throws Exception {
  String ddl =     "CREATE VIEW G1( e1 integer, e2 varchar) AS select * from foo;" +
          "CREATE TRIGGER ON G1 INSTEAD OF INSERT AS " +
          "FOR EACH ROW \n" +
          "BEGIN ATOMIC \n" +
          "insert into g1 (e1, e2) values (1, 'trig');\n" +
          "END;" +
          "CREATE View G2( e1 integer, e2 varchar) AS select * from foo;";
  Schema s = helpParse(ddl, "model").getSchema();
  Map<String, Table> tableMap = s.getTables();
  
  assertTrue("Table not found", tableMap.containsKey("G1"));
  assertTrue("Table not found", tableMap.containsKey("G2"));
  assertEquals("FOR EACH ROW\nBEGIN ATOMIC\nINSERT INTO g1 (e1, e2) VALUES (1, 'trig');\nEND", s.getTable("G1").getInsertPlan());
}

代码示例来源:origin: org.teiid/teiid-spring-boot-starter

@Test
public void testRedirectionLayerInsertPlan() {
  RedirectionSchemaBuilder mg = new RedirectionSchemaBuilder(this.context, "redirected");
  VDBMetaData vdb = new VDBMetaData();
  vdb.addModel(buildSourceTable());
  ModelMetaData model = mg.buildRedirectionLayer(buildSourceTableWithPK().getAttachment(MetadataFactory.class),
      "base");
  String expected = "FOR EACH ROW\n" + "BEGIN ATOMIC\n"
      + "    DECLARE boolean VARIABLES.Person_PK_EXISTS = (SELECT true FROM source.Person WHERE id = NEW.id);\n"
      + "    IF (VARIABLES.Person_PK_EXISTS)\n" + "    BEGIN\n"
      + "        RAISE SQLEXCEPTION 'duplicate key';\n" + "    END\n" + "    ELSE\n" + "    BEGIN\n"
      + "        INSERT INTO redirected.Person_REDIRECTED (id, name, dob, ROW__STATUS) VALUES (NEW.id, NEW.name, NEW.dob, 1);\n"
      + "    END\n" + "END";
  MetadataFactory mf = model.getAttachment(MetadataFactory.class);
  Table table = mf.getSchema().getTable("Person");
  assertEquals(expected, table.getInsertPlan().replace("\t", "    "));
}

代码示例来源:origin: org.jboss.teiid/teiid-engine

buildTrigger(name, null, INSERT, table.getInsertPlan(), false);

代码示例来源:origin: org.teiid/teiid-engine

if (t.getInsertPlan() != null && t.isInsertPlanEnabled()) {
  validateUpdatePlan(model, report, metadata, t, t.getInsertPlan(), Command.TYPE_INSERT);

代码示例来源:origin: teiid/teiid

if (t.getInsertPlan() != null && t.isInsertPlanEnabled()) {
  validateUpdatePlan(model, report, metadata, t, t.getInsertPlan(), Command.TYPE_INSERT);

代码示例来源:origin: org.jboss.teiid/teiid-engine

if (t.getInsertPlan() != null && t.isInsertPlanEnabled()) {
  validateUpdatePlan(model, report, metadata, t, t.getInsertPlan(), Command.TYPE_INSERT);

代码示例来源:origin: teiid/teiid

buildTrigger(name, null, INSERT, table.getInsertPlan(), false);

代码示例来源:origin: org.teiid/teiid-engine

buildTrigger(name, null, INSERT, table.getInsertPlan(), false);

相关文章

微信公众号

最新文章

更多