public class org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter extends java.lang.Object
{
private final org.apache.nifi.processors.standard.db.DatabaseAdapter db;
public void <init>()
{
org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter v;
org.apache.nifi.processors.standard.db.impl.OracleDatabaseAdapter v;
v := @this: org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new org.apache.nifi.processors.standard.db.impl.OracleDatabaseAdapter;
specialinvoke v.<org.apache.nifi.processors.standard.db.impl.OracleDatabaseAdapter: void <init>()>();
v.<org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter: org.apache.nifi.processors.standard.db.DatabaseAdapter db> = v;
return;
}
public void testGeneration()
{
org.apache.nifi.processors.standard.db.DatabaseAdapter v, v, v, v;
org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter v;
java.lang.String v, v, v, v;
v := @this: org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter;
v = v.<org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter: org.apache.nifi.processors.standard.db.DatabaseAdapter db>;
v = interfaceinvoke v.<org.apache.nifi.processors.standard.db.DatabaseAdapter: java.lang.String getSelectStatement(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.Long,java.lang.Long)>("database.tablename", "some(set),of(columns),that,might,contain,methods,a.*", "", "", null, null);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("SELECT some(set),of(columns),that,might,contain,methods,a.* FROM database.tablename", v);
v = v.<org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter: org.apache.nifi.processors.standard.db.DatabaseAdapter db>;
v = interfaceinvoke v.<org.apache.nifi.processors.standard.db.DatabaseAdapter: java.lang.String getSelectStatement(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.Long,java.lang.Long)>("database.tablename", "some(set),of(columns),that,might,contain,methods,a.*", "that=\'some\"\' value\'", "", null, null);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("SELECT some(set),of(columns),that,might,contain,methods,a.* FROM database.tablename WHERE that=\'some\"\' value\'", v);
v = v.<org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter: org.apache.nifi.processors.standard.db.DatabaseAdapter db>;
v = interfaceinvoke v.<org.apache.nifi.processors.standard.db.DatabaseAdapter: java.lang.String getSelectStatement(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.Long,java.lang.Long)>("database.tablename", "some(set),of(columns),that,might,contain,methods,a.*", "that=\'some\"\' value\'", "might DESC", null, null);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("SELECT some(set),of(columns),that,might,contain,methods,a.* FROM database.tablename WHERE that=\'some\"\' value\' ORDER BY might DESC", v);
v = v.<org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter: org.apache.nifi.processors.standard.db.DatabaseAdapter db>;
v = interfaceinvoke v.<org.apache.nifi.processors.standard.db.DatabaseAdapter: java.lang.String getSelectStatement(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.Long,java.lang.Long)>("database.tablename", "", "that=\'some\"\' value\'", "might DESC", null, null);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("SELECT * FROM database.tablename WHERE that=\'some\"\' value\' ORDER BY might DESC", v);
return;
}
public void testNoTableName()
{
org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter v;
org.junit.jupiter.api.function.Executable v;
v := @this: org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter;
v = staticinvoke <org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter$lambda_testNoTableName_0__282: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/lang/IllegalArgumentException;", v);
return;
}
public void testPagingQuery()
{
java.lang.Long v, v, v, v, v, v, v;
java.lang.String v, v, v, v;
org.apache.nifi.processors.standard.db.DatabaseAdapter v, v, v, v;
org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter v;
v := @this: org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter;
v = v.<org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter: org.apache.nifi.processors.standard.db.DatabaseAdapter db>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(100L);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(0L);
v = interfaceinvoke v.<org.apache.nifi.processors.standard.db.DatabaseAdapter: java.lang.String getSelectStatement(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.Long,java.lang.Long)>("database.tablename", "some(set),of(columns),that,might,contain,methods,a.*", "", "contain", v, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("SELECT some(set),of(columns),that,might,contain,methods,a.* FROM (SELECT a.*, ROWNUM rnum FROM (SELECT some(set),of(columns),that,might,contain,methods,a.* FROM database.tablename ORDER BY contain) a WHERE ROWNUM <= 100) WHERE rnum > 0", v);
v = v.<org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter: org.apache.nifi.processors.standard.db.DatabaseAdapter db>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(10000L);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(123456L);
v = interfaceinvoke v.<org.apache.nifi.processors.standard.db.DatabaseAdapter: java.lang.String getSelectStatement(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.Long,java.lang.Long)>("database.tablename", "some(set),of(columns),that,might,contain,methods,a.*", "", "contain", v, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("SELECT some(set),of(columns),that,might,contain,methods,a.* FROM (SELECT a.*, ROWNUM rnum FROM (SELECT some(set),of(columns),that,might,contain,methods,a.* FROM database.tablename ORDER BY contain) a WHERE ROWNUM <= 133456) WHERE rnum > 123456", v);
v = v.<org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter: org.apache.nifi.processors.standard.db.DatabaseAdapter db>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(10000L);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(123456L);
v = interfaceinvoke v.<org.apache.nifi.processors.standard.db.DatabaseAdapter: java.lang.String getSelectStatement(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.Long,java.lang.Long)>("database.tablename", "some(set),of(columns),that,might,contain,methods,a.*", "methods=\'strange\'", "contain", v, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("SELECT some(set),of(columns),that,might,contain,methods,a.* FROM (SELECT a.*, ROWNUM rnum FROM (SELECT some(set),of(columns),that,might,contain,methods,a.* FROM database.tablename WHERE methods=\'strange\' ORDER BY contain) a WHERE ROWNUM <= 133456) WHERE rnum > 123456", v);
v = v.<org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter: org.apache.nifi.processors.standard.db.DatabaseAdapter db>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(100L);
v = interfaceinvoke v.<org.apache.nifi.processors.standard.db.DatabaseAdapter: java.lang.String getSelectStatement(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.Long,java.lang.Long)>("database.tablename", "some(set),of(columns),that,might,contain,methods,a.*", "", "", v, null);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("SELECT some(set),of(columns),that,might,contain,methods,a.* FROM (SELECT a.*, ROWNUM rnum FROM (SELECT some(set),of(columns),that,might,contain,methods,a.* FROM database.tablename) a WHERE ROWNUM <= 100) WHERE rnum > 0", v);
return;
}
public void testPagingQueryUsingColumnValuesForPartitioning()
{
java.lang.Long v, v, v, v, v, v, v;
java.lang.String v, v, v, v;
org.apache.nifi.processors.standard.db.DatabaseAdapter v, v, v, v;
org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter v;
v := @this: org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter;
v = v.<org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter: org.apache.nifi.processors.standard.db.DatabaseAdapter db>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(100L);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(0L);
v = interfaceinvoke v.<org.apache.nifi.processors.standard.db.DatabaseAdapter: java.lang.String getSelectStatement(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.Long,java.lang.Long,java.lang.String)>("database.tablename", "some(set),of(columns),that,might,contain,methods,a.*", "1=1", "contain", v, v, "contain");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("SELECT some(set),of(columns),that,might,contain,methods,a.* FROM database.tablename WHERE 1=1 AND contain >= 0 AND contain < 100", v);
v = v.<org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter: org.apache.nifi.processors.standard.db.DatabaseAdapter db>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(10000L);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(123456L);
v = interfaceinvoke v.<org.apache.nifi.processors.standard.db.DatabaseAdapter: java.lang.String getSelectStatement(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.Long,java.lang.Long,java.lang.String)>("database.tablename", "some(set),of(columns),that,might,contain,methods,a.*", "1=1", "contain", v, v, "contain");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("SELECT some(set),of(columns),that,might,contain,methods,a.* FROM database.tablename WHERE 1=1 AND contain >= 123456 AND contain < 133456", v);
v = v.<org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter: org.apache.nifi.processors.standard.db.DatabaseAdapter db>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(10000L);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(123456L);
v = interfaceinvoke v.<org.apache.nifi.processors.standard.db.DatabaseAdapter: java.lang.String getSelectStatement(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.Long,java.lang.Long,java.lang.String)>("database.tablename", "some(set),of(columns),that,might,contain,methods,a.*", "methods=\'strange\'", "contain", v, v, "contain");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("SELECT some(set),of(columns),that,might,contain,methods,a.* FROM database.tablename WHERE methods=\'strange\' AND contain >= 123456 AND contain < 133456", v);
v = v.<org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter: org.apache.nifi.processors.standard.db.DatabaseAdapter db>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(100L);
v = interfaceinvoke v.<org.apache.nifi.processors.standard.db.DatabaseAdapter: java.lang.String getSelectStatement(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.Long,java.lang.Long,java.lang.String)>("database.tablename", "some(set),of(columns),that,might,contain,methods,a.*", "", "", v, null, "contain");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("SELECT some(set),of(columns),that,might,contain,methods,a.* FROM database.tablename", v);
return;
}
public void testGetCreateTableStatement()
{
org.apache.nifi.processors.standard.db.DatabaseAdapter v, v, v;
org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter v;
java.util.Set v;
java.lang.Integer v, v;
java.util.List v;
org.apache.nifi.processors.standard.db.ColumnDescription v, v;
org.apache.nifi.processors.standard.db.TableSchema v;
java.lang.String v, v;
org.apache.nifi.processors.standard.db.ColumnDescription[] v;
boolean v;
v := @this: org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter;
v = v.<org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter: org.apache.nifi.processors.standard.db.DatabaseAdapter db>;
v = interfaceinvoke v.<org.apache.nifi.processors.standard.db.DatabaseAdapter: boolean supportsCreateTableIfNotExists()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = newarray (org.apache.nifi.processors.standard.db.ColumnDescription)[2];
v = new org.apache.nifi.processors.standard.db.ColumnDescription;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(4);
specialinvoke v.<org.apache.nifi.processors.standard.db.ColumnDescription: void <init>(java.lang.String,int,boolean,java.lang.Integer,boolean)>("col1", 4, 1, v, 0);
v[0] = v;
v = new org.apache.nifi.processors.standard.db.ColumnDescription;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2000);
specialinvoke v.<org.apache.nifi.processors.standard.db.ColumnDescription: void <init>(java.lang.String,int,boolean,java.lang.Integer,boolean)>("col2", 12, 0, v, 1);
v[1] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = new org.apache.nifi.processors.standard.db.TableSchema;
v = staticinvoke <java.util.Collections: java.util.Set singleton(java.lang.Object)>("COL1");
v = v.<org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter: org.apache.nifi.processors.standard.db.DatabaseAdapter db>;
v = interfaceinvoke v.<org.apache.nifi.processors.standard.db.DatabaseAdapter: java.lang.String getColumnQuoteString()>();
specialinvoke v.<org.apache.nifi.processors.standard.db.TableSchema: void <init>(java.lang.String,java.lang.String,java.lang.String,java.util.List,boolean,java.util.Set,java.lang.String)>("USERS", null, "TEST_TABLE", v, 1, v, v);
v = v.<org.apache.nifi.processors.standard.db.impl.TestOracleDatabaseAdapter: org.apache.nifi.processors.standard.db.DatabaseAdapter db>;
v = interfaceinvoke v.<org.apache.nifi.processors.standard.db.DatabaseAdapter: java.lang.String getCreateTableStatement(org.apache.nifi.processors.standard.db.TableSchema,boolean,boolean)>(v, 1, 1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("DECLARE\n\tsql_stmt long;\nBEGIN\n\tsql_stmt:=\'CREATE TABLE \"USERS\".\"TEST_TABLE\" (\"col1\" INTEGER NOT NULL, \"col2\" VARCHAR2(2000))\';\nEXECUTE IMMEDIATE sql_stmt;\nEXCEPTION\n\tWHEN OTHERS THEN\n\t\tIF SQLCODE = -955 THEN\n\t\t\tNULL;\n\t\tELSE\n\t\t\tRAISE;\n\t\tEND IF;\nEND;", v);
return;
}
}