本文整理了Java中org.teiid.metadata.Table.getSelectTransformation()
方法的一些代码示例,展示了Table.getSelectTransformation()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Table.getSelectTransformation()
方法的具体详情如下:
包路径:org.teiid.metadata.Table
类名称:Table
方法名:getSelectTransformation
暂无
代码示例来源:origin: teiid/teiid
public String getQuery() {
return t.getSelectTransformation();
}
}
代码示例来源:origin: org.jboss.teiid/teiid-engine
public String getQuery() {
return t.getSelectTransformation();
}
}
代码示例来源:origin: org.teiid/teiid-engine
public String getQuery() {
return t.getSelectTransformation();
}
}
代码示例来源:origin: org.jboss.teiid/teiid-engine
public MappingNode getMappingNode(final Object groupID) throws TeiidComponentException, QueryMetadataException {
Table tableRecord = (Table) groupID;
MappingDocument mappingDoc = (MappingDocument) getFromMetadataCache(groupID, "xml-doc"); //$NON-NLS-1$
if (mappingDoc != null) {
return mappingDoc;
}
final String groupName = tableRecord.getFullName();
if(tableRecord.isVirtual()) {
// get mapping transform
String document = tableRecord.getSelectTransformation();
InputStream inputStream = new ByteArrayInputStream(document.getBytes());
MappingLoader reader = new MappingLoader();
try{
mappingDoc = reader.loadDocument(inputStream);
mappingDoc.setName(groupName);
} catch (Exception e){
throw new TeiidComponentException(QueryPlugin.Event.TEIID30363, e, QueryPlugin.Util.gs(QueryPlugin.Event.TEIID30363, groupName, mappingDoc));
} finally {
try {
inputStream.close();
} catch(Exception e) {}
}
addToMetadataCache(groupID, "xml-doc", mappingDoc); //$NON-NLS-1$
return mappingDoc;
}
return null;
}
代码示例来源:origin: org.teiid/teiid-engine
public static void alterView(final VDBMetaData vdb, final Table t, final String sql, boolean updateStore) {
TransformationMetadata metadata = vdb.getAttachment(TransformationMetadata.class);
DatabaseStore store = vdb.getAttachment(DatabaseStore.class);
try {
Command command = QueryParser.getQueryParser().parseCommand(t.getSelectTransformation());
QueryResolver.resolveCommand(command, metadata);
MetadataValidator.determineDependencies(t, command);
} catch (TeiidException e) {
//should have been caught in validation, but this logic
//is also not mature so since there is no lock on the vdb
//it is possible that the plan is no longer valid at this point due
//to a concurrent execution
}
t.setSelectTransformation(sql);
t.setLastModified(System.currentTimeMillis());
metadata.addToMetadataCache(t, "transformation/"+SQLConstants.Reserved.SELECT, null); //$NON-NLS-1$
}
代码示例来源:origin: org.jboss.teiid/teiid-engine
public static void alterView(final VDBMetaData vdb, final Table t, final String sql, boolean updateStore) {
TransformationMetadata metadata = vdb.getAttachment(TransformationMetadata.class);
DatabaseStore store = vdb.getAttachment(DatabaseStore.class);
try {
Command command = QueryParser.getQueryParser().parseCommand(t.getSelectTransformation());
QueryResolver.resolveCommand(command, metadata);
MetadataValidator.determineDependencies(t, command);
} catch (TeiidException e) {
//should have been caught in validation, but this logic
//is also not mature so since there is no lock on the vdb
//it is possible that the plan is no longer valid at this point due
//to a concurrent execution
}
t.setSelectTransformation(sql);
t.setLastModified(System.currentTimeMillis());
metadata.addToMetadataCache(t, "transformation/"+SQLConstants.Reserved.SELECT, null); //$NON-NLS-1$
}
代码示例来源:origin: teiid/teiid
public static void alterView(final VDBMetaData vdb, final Table t, final String sql, boolean updateStore) {
TransformationMetadata metadata = vdb.getAttachment(TransformationMetadata.class);
DatabaseStore store = vdb.getAttachment(DatabaseStore.class);
try {
Command command = QueryParser.getQueryParser().parseCommand(t.getSelectTransformation());
QueryResolver.resolveCommand(command, metadata);
MetadataValidator.determineDependencies(t, command);
} catch (TeiidException e) {
//should have been caught in validation, but this logic
//is also not mature so since there is no lock on the vdb
//it is possible that the plan is no longer valid at this point due
//to a concurrent execution
}
t.setSelectTransformation(sql);
t.setLastModified(System.currentTimeMillis());
metadata.addToMetadataCache(t, "transformation/"+SQLConstants.Reserved.SELECT, null); //$NON-NLS-1$
}
代码示例来源:origin: org.teiid/teiid-engine
public void tableCreated(Table table) {
if (!assertInEditMode(Mode.SCHEMA)) {
return;
}
assertGrant(Grant.Permission.Privilege.CREATE, Database.ResourceType.TABLE, table);
Schema s = getCurrentSchema();
setUUID(s.getUUID(), table);
if (table.isVirtual() && table.getSelectTransformation() == null && table.getTableType() != Type.TemporaryTable) {
throw new org.teiid.metadata.MetadataException(QueryPlugin.Event.TEIID31272,
QueryPlugin.Util.gs(QueryPlugin.Event.TEIID31272, table.getFullName()));
}
s.addTable(table);
}
代码示例来源:origin: teiid/teiid
@Test
public void testView() throws Exception {
String ddl = "CREATE View G1( e1 integer, e2 varchar) OPTIONS (CARDINALITY 12) AS select e1, e2 from foo.bar";
Schema s = helpParse(ddl, "model").getSchema();
Map<String, Table> tableMap = s.getTables();
Table table = tableMap.get("G1");
assertEquals("SELECT e1, e2 FROM foo.bar", table.getSelectTransformation());
assertEquals(12, table.getCardinality());
}
代码示例来源:origin: teiid/teiid
public void tableCreated(Table table) {
if (!assertInEditMode(Mode.SCHEMA)) {
return;
}
assertGrant(Grant.Permission.Privilege.CREATE, Database.ResourceType.TABLE, table);
Schema s = getCurrentSchema();
setUUID(s.getUUID(), table);
if (table.isVirtual() && table.getSelectTransformation() == null && table.getTableType() != Type.TemporaryTable) {
throw new org.teiid.metadata.MetadataException(QueryPlugin.Event.TEIID31272,
QueryPlugin.Util.gs(QueryPlugin.Event.TEIID31272, table.getFullName()));
}
s.addTable(table);
}
代码示例来源:origin: teiid/teiid
@Test
public void testAlterView() throws Exception {
String ddl = "CREATE DATABASE FOO;"
+ "USE DATABASE FOO ;"
+ "CREATE VIRTUAL SCHEMA test;"
+ "SET SCHEMA test;"
+ "CREATE VIRTUAL VIEW G1( e1 integer, e2 varchar, e3 date) AS SELECT 1, '2', curdate();"
+ "ALTER VIEW G1 AS /*+ foo */ SELECT 1, 'foo', curdate()";
Database db = helpParse(ddl);
Schema s = db.getSchema("test");
Table t = s.getTable("G1");
assertEquals("SELECT 1, 'foo', curdate()", t.getSelectTransformation());
}
代码示例来源:origin: teiid/teiid
@Test
public void testAlterViewAddColumn2() throws Exception {
String ddl = "CREATE DATABASE FOO;"
+ "USE DATABASE FOO ;"
+ "CREATE VIRTUAL SCHEMA test;"
+ "SET SCHEMA test;"
+ "CREATE VIRTUAL VIEW G1 AS SELECT 1 as e1, '2' as e2, curdate() as e3;"
+ "ALTER VIEW G1 AS SELECT 1 as e1, '2' as e2, curdate() as e3, 'foo' as e4;";
Database db = helpParse(ddl);
Schema s = db.getSchema("test");
Table t = s.getTable("G1");
assertEquals("SELECT 1 AS e1, '2' AS e2, curdate() AS e3, 'foo' AS e4", t.getSelectTransformation());
}
代码示例来源:origin: teiid/teiid
@Test
public void testMultipleCommands() throws Exception {
String ddl = "CREATE VIEW V1 AS SELECT * FROM PM1.G1; " +
"CREATE PROCEDURE FOO(P1 integer) RETURNS (e1 integer, e2 varchar) AS SELECT * FROM PM1.G1;";
Schema s = helpParse(ddl, "model").getSchema();
Map<String, Table> tableMap = s.getTables();
Table table = tableMap.get("V1");
assertNotNull(table);
assertEquals("SELECT * FROM PM1.G1", table.getSelectTransformation());
Map<String, Procedure> procedureMap = s.getProcedures();
Procedure p = procedureMap.get("FOO");
assertNotNull(p);
assertEquals("SELECT * FROM PM1.G1;", p.getQueryPlan());
}
代码示例来源:origin: org.jboss.teiid/teiid-engine
append(NEWLINE).append(SQLConstants.Reserved.AS).append(NEWLINE).append(table.getSelectTransformation());
代码示例来源:origin: org.teiid/teiid-spring-boot-starter
@Test
public void testRedirectionLayerSelectPlan() {
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 = "SELECT o.id, o.name, o.dob FROM internal.Person AS o LEFT OUTER JOIN "
+ "redirected.Person_REDIRECTED AS m ON (o.id = m.id) WHERE m.ROW__STATUS IS NULL \n" + " UNION ALL \n"
+ "SELECT id, name, dob FROM redirected.Person_REDIRECTED WHERE ROW__STATUS <> 3";
MetadataFactory mf = model.getAttachment(MetadataFactory.class);
Table table = mf.getSchema().getTable("Person");
assertEquals(expected, table.getSelectTransformation());
}
代码示例来源:origin: teiid/teiid
append(NEWLINE).append(SQLConstants.Reserved.AS).append(NEWLINE).append(table.getSelectTransformation());
代码示例来源:origin: teiid/teiid
if (t.getSelectTransformation() == null) {
metadataValidator.log(report, model, QueryPlugin.Util.gs(QueryPlugin.Event.TEIID31079, t.getFullName(), model.getName()));
代码示例来源:origin: org.teiid/teiid-engine
append(NEWLINE).append(SQLConstants.Reserved.AS).append(NEWLINE).append(table.getSelectTransformation());
代码示例来源:origin: org.jboss.teiid/teiid-engine
if (t.getSelectTransformation() == null) {
metadataValidator.log(report, model, QueryPlugin.Util.gs(QueryPlugin.Event.TEIID31079, t.getFullName(), model.getName()));
代码示例来源:origin: org.teiid/teiid-engine
if (t.getSelectTransformation() == null) {
metadataValidator.log(report, model, QueryPlugin.Util.gs(QueryPlugin.Event.TEIID31079, t.getFullName(), model.getName()));
内容来源于网络,如有侵权,请联系作者删除!