public class org.apache.nifi.registry.db.migration.LegacyDatabaseService extends java.lang.Object
{
private final org.springframework.jdbc.core.JdbcTemplate jdbcTemplate;
public void <init>(javax.sql.DataSource)
{
javax.sql.DataSource v;
org.apache.nifi.registry.db.migration.LegacyDatabaseService v;
org.springframework.jdbc.core.JdbcTemplate v;
v := @this: org.apache.nifi.registry.db.migration.LegacyDatabaseService;
v := @parameter: javax.sql.DataSource;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new org.springframework.jdbc.core.JdbcTemplate;
specialinvoke v.<org.springframework.jdbc.core.JdbcTemplate: void <init>(javax.sql.DataSource)>(v);
v.<org.apache.nifi.registry.db.migration.LegacyDatabaseService: org.springframework.jdbc.core.JdbcTemplate jdbcTemplate> = v;
return;
}
public java.util.List getAllBuckets()
{
org.apache.nifi.registry.db.migration.LegacyDatabaseService v;
java.util.List v;
org.springframework.jdbc.core.RowMapper v;
org.springframework.jdbc.core.JdbcTemplate v;
v := @this: org.apache.nifi.registry.db.migration.LegacyDatabaseService;
v = v.<org.apache.nifi.registry.db.migration.LegacyDatabaseService: org.springframework.jdbc.core.JdbcTemplate jdbcTemplate>;
v = staticinvoke <org.apache.nifi.registry.db.migration.LegacyDatabaseService$lambda_getAllBuckets_0__14: org.springframework.jdbc.core.RowMapper bootstrap$()>();
v = virtualinvoke v.<org.springframework.jdbc.core.JdbcTemplate: java.util.List query(java.lang.String,org.springframework.jdbc.core.RowMapper)>("SELECT * FROM bucket ORDER BY name ASC", v);
return v;
}
public java.util.List getAllFlows()
{
org.apache.nifi.registry.db.migration.LegacyDatabaseService v;
java.util.List v;
org.springframework.jdbc.core.RowMapper v;
org.springframework.jdbc.core.JdbcTemplate v;
v := @this: org.apache.nifi.registry.db.migration.LegacyDatabaseService;
v = v.<org.apache.nifi.registry.db.migration.LegacyDatabaseService: org.springframework.jdbc.core.JdbcTemplate jdbcTemplate>;
v = staticinvoke <org.apache.nifi.registry.db.migration.LegacyDatabaseService$lambda_getAllFlows_1__15: org.springframework.jdbc.core.RowMapper bootstrap$()>();
v = virtualinvoke v.<org.springframework.jdbc.core.JdbcTemplate: java.util.List query(java.lang.String,org.springframework.jdbc.core.RowMapper)>("SELECT * FROM flow f, bucket_item item WHERE item.id = f.id", v);
return v;
}
public java.util.List getAllFlowSnapshots()
{
org.apache.nifi.registry.db.migration.LegacyDatabaseService v;
java.util.List v;
org.springframework.jdbc.core.RowMapper v;
org.springframework.jdbc.core.JdbcTemplate v;
v := @this: org.apache.nifi.registry.db.migration.LegacyDatabaseService;
v = v.<org.apache.nifi.registry.db.migration.LegacyDatabaseService: org.springframework.jdbc.core.JdbcTemplate jdbcTemplate>;
v = staticinvoke <org.apache.nifi.registry.db.migration.LegacyDatabaseService$lambda_getAllFlowSnapshots_2__16: org.springframework.jdbc.core.RowMapper bootstrap$()>();
v = virtualinvoke v.<org.springframework.jdbc.core.JdbcTemplate: java.util.List query(java.lang.String,org.springframework.jdbc.core.RowMapper)>("SELECT * FROM flow_snapshot fs", v);
return v;
}
}