public class org.apache.nifi.registry.db.DatabaseMetadataService extends java.lang.Object implements org.apache.nifi.registry.service.MetadataService { private final org.springframework.jdbc.core.JdbcTemplate jdbcTemplate; private static final java.lang.String BASE_BUCKET_ITEMS_SQL; private static final java.lang.String BASE_BUNDLE_SQL; private static final java.lang.String BASE_EXTENSION_BUNDLE_VERSION_SQL; private static java.lang.String BASE_EXTENSION_SQL; public void (org.springframework.jdbc.core.JdbcTemplate) { org.apache.nifi.registry.db.DatabaseMetadataService v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: org.springframework.jdbc.core.JdbcTemplate; specialinvoke v.()>(); v. = v; return; } public org.apache.nifi.registry.db.entity.BucketEntity createBucket(org.apache.nifi.registry.db.entity.BucketEntity) { java.lang.Object[] v; java.util.Date v; java.lang.Integer v, v; org.springframework.jdbc.core.JdbcTemplate v; org.apache.nifi.registry.db.entity.BucketEntity v; byte v, v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.String v, v, v; boolean v, v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: org.apache.nifi.registry.db.entity.BucketEntity; v = v.; v = newarray (java.lang.Object)[6]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; v = virtualinvoke v.(); v[3] = v; v = virtualinvoke v.(); if v == 0 goto label; v = 1; goto label; label: v = 0; label: v = staticinvoke (v); v[4] = v; v = virtualinvoke v.(); if v == 0 goto label; v = 1; goto label; label: v = 0; label: v = staticinvoke (v); v[5] = v; virtualinvoke v.("INSERT INTO BUCKET (ID, NAME, DESCRIPTION, CREATED, ALLOW_EXTENSION_BUNDLE_REDEPLOY, ALLOW_PUBLIC_READ) VALUES (?, ?, ?, ?, ?, ?)", v); return v; } public org.apache.nifi.registry.db.entity.BucketEntity getBucketById(java.lang.String) { java.lang.Throwable v; java.lang.Object[] v; org.apache.nifi.registry.db.DatabaseMetadataService v; org.apache.nifi.registry.db.mapper.BucketEntityRowMapper v; java.lang.Object v; java.lang.String v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; label: v = v.; v = new org.apache.nifi.registry.db.mapper.BucketEntityRowMapper; specialinvoke v.()>(); v = newarray (java.lang.Object)[1]; v[0] = v; v = virtualinvoke v.("SELECT * FROM BUCKET WHERE id = ?", v, v); label: return v; label: v := @caughtexception; return null; catch org.springframework.dao.EmptyResultDataAccessException from label to label with label; } public java.util.List getBucketsByName(java.lang.String) { java.util.List v; java.lang.Object[] v; org.apache.nifi.registry.db.DatabaseMetadataService v; org.apache.nifi.registry.db.mapper.BucketEntityRowMapper v; java.lang.String v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v = v.; v = newarray (java.lang.Object)[1]; v[0] = v; v = new org.apache.nifi.registry.db.mapper.BucketEntityRowMapper; specialinvoke v.()>(); v = virtualinvoke v.("SELECT * FROM BUCKET WHERE name = ? ORDER BY name ASC", v, v); return v; } public org.apache.nifi.registry.db.entity.BucketEntity updateBucket(org.apache.nifi.registry.db.entity.BucketEntity) { java.lang.Object[] v; java.lang.Integer v, v; org.springframework.jdbc.core.JdbcTemplate v; org.apache.nifi.registry.db.entity.BucketEntity v; byte v, v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.String v, v, v; boolean v, v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: org.apache.nifi.registry.db.entity.BucketEntity; v = v.; v = newarray (java.lang.Object)[5]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); if v == 0 goto label; v = 1; goto label; label: v = 0; label: v = staticinvoke (v); v[2] = v; v = virtualinvoke v.(); if v == 0 goto label; v = 1; goto label; label: v = 0; label: v = staticinvoke (v); v[3] = v; v = virtualinvoke v.(); v[4] = v; virtualinvoke v.("UPDATE BUCKET SET name = ?, description = ?, allow_extension_bundle_redeploy = ?, allow_public_read = ? WHERE id = ?", v); return v; } public void deleteBucket(org.apache.nifi.registry.db.entity.BucketEntity) { org.apache.nifi.registry.db.entity.BucketEntity v; java.lang.Object[] v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.String v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: org.apache.nifi.registry.db.entity.BucketEntity; v = v.; v = newarray (java.lang.Object)[1]; v = virtualinvoke v.(); v[0] = v; virtualinvoke v.("DELETE FROM BUCKET WHERE id = ?", v); return; } public java.util.List getBuckets(java.util.Set) { java.lang.Object[] v; java.util.Set v; org.springframework.jdbc.core.JdbcTemplate v; java.util.List v, v; org.apache.nifi.registry.db.DatabaseMetadataService v; org.apache.nifi.registry.db.mapper.BucketEntityRowMapper v; java.lang.StringBuilder v; java.lang.String v; boolean v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.util.Set; if v == null goto label; v = interfaceinvoke v.(); if v == 0 goto label; label: v = staticinvoke (); return v; label: v = new java.lang.StringBuilder; specialinvoke v.(java.lang.String)>("SELECT * FROM BUCKET WHERE "); specialinvoke v.(v, "id", v); virtualinvoke v.("ORDER BY name ASC"); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = new org.apache.nifi.registry.db.mapper.BucketEntityRowMapper; specialinvoke v.()>(); v = virtualinvoke v.(v, v, v); return v; } public java.util.List getAllBuckets() { java.util.List v; org.apache.nifi.registry.db.DatabaseMetadataService v; org.apache.nifi.registry.db.mapper.BucketEntityRowMapper v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v = v.; v = new org.apache.nifi.registry.db.mapper.BucketEntityRowMapper; specialinvoke v.()>(); v = virtualinvoke v.("SELECT * FROM BUCKET ORDER BY name ASC", v); return v; } public java.util.List getBucketItems(java.lang.String) { org.apache.nifi.registry.db.mapper.BucketItemEntityRowMapper v; java.util.List v, v; java.lang.Object[] v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.String v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v = v.; v = newarray (java.lang.Object)[1]; v[0] = v; v = new org.apache.nifi.registry.db.mapper.BucketItemEntityRowMapper; specialinvoke v.()>(); v = virtualinvoke v.("SELECT item.id as ID, item.name as NAME, item.description as DESCRIPTION, item.created as CREATED, item.modified as MODIFIED, item.item_type as ITEM_TYPE, b.id as BUCKET_ID, b.name as BUCKET_NAME ,eb.bundle_type as BUNDLE_TYPE, eb.group_id as BUNDLE_GROUP_ID, eb.artifact_id as BUNDLE_ARTIFACT_ID FROM BUCKET_ITEM item INNER JOIN BUCKET b ON item.bucket_id = b.id LEFT JOIN BUNDLE eb ON item.id = eb.id WHERE item.bucket_id = ?", v, v); v = specialinvoke v.(v); return v; } public java.util.List getBucketItems(java.util.Set) { java.lang.Object[] v; java.util.Set v; org.springframework.jdbc.core.JdbcTemplate v; org.apache.nifi.registry.db.mapper.BucketItemEntityRowMapper v; java.util.List v, v, v; org.apache.nifi.registry.db.DatabaseMetadataService v; int v, v; java.lang.StringBuilder v; java.lang.String v; boolean v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.util.Set; if v == null goto label; v = interfaceinvoke v.(); if v == 0 goto label; label: v = staticinvoke (); return v; label: v = new java.lang.StringBuilder; specialinvoke v.(java.lang.String)>("SELECT item.id as ID, item.name as NAME, item.description as DESCRIPTION, item.created as CREATED, item.modified as MODIFIED, item.item_type as ITEM_TYPE, b.id as BUCKET_ID, b.name as BUCKET_NAME ,eb.bundle_type as BUNDLE_TYPE, eb.group_id as BUNDLE_GROUP_ID, eb.artifact_id as BUNDLE_ARTIFACT_ID FROM BUCKET_ITEM item INNER JOIN BUCKET b ON item.bucket_id = b.id LEFT JOIN BUNDLE eb ON item.id = eb.id WHERE item.bucket_id IN ("); v = 0; label: v = interfaceinvoke v.(); if v >= v goto label; if v <= 0 goto label; virtualinvoke v.(", "); label: virtualinvoke v.("?"); v = v + 1; goto label; label: virtualinvoke v.(")"); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = new org.apache.nifi.registry.db.mapper.BucketItemEntityRowMapper; specialinvoke v.()>(); v = virtualinvoke v.(v, v, v); v = specialinvoke v.(v); return v; } private java.util.List getItemsWithCounts(java.lang.Iterable) { long v, v; java.lang.Iterable v; java.util.ArrayList v; org.apache.nifi.registry.db.entity.BucketItemEntity v; org.apache.nifi.registry.db.entity.BucketItemEntityType v, v, v, v; java.util.Map v, v; java.lang.String v, v; boolean v; java.util.Iterator v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.Object v, v, v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.Iterable; v = specialinvoke v.(); v = specialinvoke v.(); v = new java.util.ArrayList; specialinvoke v.()>(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = ; if v != v goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = ; if v != v goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: interfaceinvoke v.(v); goto label; label: return v; } private java.util.Map getFlowSnapshotCounts() { org.springframework.jdbc.core.RowCallbackHandler v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.util.HashMap v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v = new java.util.HashMap; specialinvoke v.()>(); v = v.; v = staticinvoke (v); virtualinvoke v.("SELECT flow_id, count(*) FROM FLOW_SNAPSHOT GROUP BY flow_id", v); return v; } private java.lang.Long getFlowSnapshotCount(java.lang.String) { java.lang.Object[] v; org.apache.nifi.registry.db.DatabaseMetadataService v; org.springframework.jdbc.core.RowMapper v; java.lang.Object v; java.lang.String v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v = v.; v = newarray (java.lang.Object)[1]; v[0] = v; v = staticinvoke (); v = virtualinvoke v.("SELECT count(*) FROM FLOW_SNAPSHOT WHERE flow_id = ?", v, v); return v; } private java.util.Map getExtensionBundleVersionCounts() { org.springframework.jdbc.core.RowCallbackHandler v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.util.HashMap v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v = new java.util.HashMap; specialinvoke v.()>(); v = v.; v = staticinvoke (v); virtualinvoke v.("SELECT bundle_id, count(*) FROM BUNDLE_VERSION GROUP BY bundle_id", v); return v; } private java.lang.Long getExtensionBundleVersionCount(java.lang.String) { java.lang.Object[] v; org.apache.nifi.registry.db.DatabaseMetadataService v; org.springframework.jdbc.core.RowMapper v; java.lang.Object v; java.lang.String v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v = v.; v = newarray (java.lang.Object)[1]; v[0] = v; v = staticinvoke (); v = virtualinvoke v.("SELECT count(*) FROM BUNDLE_VERSION WHERE bundle_id = ?", v, v); return v; } public org.apache.nifi.registry.db.entity.FlowEntity createFlow(org.apache.nifi.registry.db.entity.FlowEntity) { java.lang.Object[] v, v; java.util.Date v, v; org.apache.nifi.registry.db.entity.FlowEntity v; org.springframework.jdbc.core.JdbcTemplate v, v; org.apache.nifi.registry.db.DatabaseMetadataService v; org.apache.nifi.registry.db.entity.BucketItemEntityType v; java.lang.String v, v, v, v, v, v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: org.apache.nifi.registry.db.entity.FlowEntity; v = v.; v = newarray (java.lang.Object)[7]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; v = virtualinvoke v.(); v[3] = v; v = virtualinvoke v.(); v[4] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v[5] = v; v = virtualinvoke v.(); v[6] = v; virtualinvoke v.("INSERT INTO BUCKET_ITEM (ID, NAME, DESCRIPTION, CREATED, MODIFIED, ITEM_TYPE, BUCKET_ID) VALUES (?, ?, ?, ?, ?, ?, ?)", v); v = v.; v = newarray (java.lang.Object)[1]; v = virtualinvoke v.(); v[0] = v; virtualinvoke v.("INSERT INTO FLOW (ID) VALUES (?)", v); return v; } public org.apache.nifi.registry.db.entity.FlowEntity getFlowById(java.lang.String) { java.lang.Throwable v; java.lang.Object[] v; org.apache.nifi.registry.db.DatabaseMetadataService v; org.apache.nifi.registry.db.mapper.FlowEntityRowMapper v; java.lang.Object v; java.lang.String v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; label: v = v.; v = new org.apache.nifi.registry.db.mapper.FlowEntityRowMapper; specialinvoke v.()>(); v = newarray (java.lang.Object)[1]; v[0] = v; v = virtualinvoke v.("SELECT * FROM FLOW f, BUCKET_ITEM item WHERE f.id = ? AND item.id = f.id", v, v); label: return v; label: v := @caughtexception; return null; catch org.springframework.dao.EmptyResultDataAccessException from label to label with label; } public org.apache.nifi.registry.db.entity.FlowEntity getFlowByIdWithSnapshotCounts(java.lang.String) { java.lang.Long v; org.apache.nifi.registry.db.DatabaseMetadataService v; long v; java.lang.String v; org.apache.nifi.registry.db.entity.FlowEntity v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v = virtualinvoke v.(v); if v != null goto label; return v; label: v = specialinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: return v; } public java.util.List getFlowsByName(java.lang.String) { java.util.List v; java.lang.Object[] v; org.apache.nifi.registry.db.DatabaseMetadataService v; org.apache.nifi.registry.db.mapper.FlowEntityRowMapper v; java.lang.String v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v = v.; v = newarray (java.lang.Object)[1]; v[0] = v; v = new org.apache.nifi.registry.db.mapper.FlowEntityRowMapper; specialinvoke v.()>(); v = virtualinvoke v.("SELECT * FROM FLOW f, BUCKET_ITEM item WHERE item.name = ? AND item.id = f.id", v, v); return v; } public java.util.List getFlowsByName(java.lang.String, java.lang.String) { java.util.List v; java.lang.Object[] v; org.apache.nifi.registry.db.DatabaseMetadataService v; org.apache.nifi.registry.db.mapper.FlowEntityRowMapper v; java.lang.String v, v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = v.; v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; v = new org.apache.nifi.registry.db.mapper.FlowEntityRowMapper; specialinvoke v.()>(); v = virtualinvoke v.("SELECT * FROM FLOW f, BUCKET_ITEM item WHERE item.name = ? AND item.id = f.id AND item.bucket_id = ?", v, v); return v; } public java.util.List getFlowsByBucket(java.lang.String) { java.lang.Object[] v; java.util.Iterator v; long v; org.springframework.jdbc.core.JdbcTemplate v; java.util.List v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.util.Map v; org.apache.nifi.registry.db.mapper.FlowEntityRowMapper v; java.lang.Object v, v; java.lang.String v, v; boolean v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v = v.; v = newarray (java.lang.Object)[1]; v[0] = v; v = new org.apache.nifi.registry.db.mapper.FlowEntityRowMapper; specialinvoke v.()>(); v = virtualinvoke v.("SELECT * FROM FLOW f, BUCKET_ITEM item WHERE item.bucket_id = ? AND item.id = f.id", v, v); v = specialinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: return v; } public org.apache.nifi.registry.db.entity.FlowEntity updateFlow(org.apache.nifi.registry.db.entity.FlowEntity) { java.lang.Object[] v; java.util.Date v, v; org.apache.nifi.registry.db.entity.FlowEntity v; org.springframework.jdbc.core.JdbcTemplate v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.String v, v, v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: org.apache.nifi.registry.db.entity.FlowEntity; v = new java.util.Date; specialinvoke v.()>(); virtualinvoke v.(v); v = v.; v = newarray (java.lang.Object)[4]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; v = virtualinvoke v.(); v[3] = v; virtualinvoke v.("UPDATE BUCKET_ITEM SET name = ?, description = ?, modified = ? WHERE id = ?", v); return v; } public void deleteFlow(org.apache.nifi.registry.db.entity.FlowEntity) { java.lang.Object[] v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.String v; org.apache.nifi.registry.db.entity.FlowEntity v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: org.apache.nifi.registry.db.entity.FlowEntity; v = v.; v = newarray (java.lang.Object)[1]; v = virtualinvoke v.(); v[0] = v; virtualinvoke v.("DELETE FROM BUCKET_ITEM WHERE id = ?", v); return; } public org.apache.nifi.registry.db.entity.FlowSnapshotEntity createFlowSnapshot(org.apache.nifi.registry.db.entity.FlowSnapshotEntity) { java.lang.Object[] v; org.apache.nifi.registry.db.entity.FlowSnapshotEntity v; java.util.Date v; java.lang.Integer v; org.springframework.jdbc.core.JdbcTemplate v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.String v, v, v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: org.apache.nifi.registry.db.entity.FlowSnapshotEntity; v = v.; v = newarray (java.lang.Object)[5]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; v = virtualinvoke v.(); v[3] = v; v = virtualinvoke v.(); v[4] = v; virtualinvoke v.("INSERT INTO FLOW_SNAPSHOT (FLOW_ID, VERSION, CREATED, CREATED_BY, COMMENTS) VALUES (?, ?, ?, ?, ?)", v); return v; } public org.apache.nifi.registry.db.entity.FlowSnapshotEntity getFlowSnapshot(java.lang.String, java.lang.Integer) { java.lang.Throwable v; java.lang.Object[] v; org.apache.nifi.registry.db.mapper.FlowSnapshotEntityRowMapper v; java.lang.Integer v; org.springframework.jdbc.core.JdbcTemplate v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.Object v; java.lang.String v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v := @parameter: java.lang.Integer; label: v = v.; v = new org.apache.nifi.registry.db.mapper.FlowSnapshotEntityRowMapper; specialinvoke v.()>(); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; v = virtualinvoke v.("SELECT fs.flow_id, fs.version, fs.created, fs.created_by, fs.comments FROM FLOW_SNAPSHOT fs, FLOW f, BUCKET_ITEM item WHERE item.id = f.id AND f.id = ? AND f.id = fs.flow_id AND fs.version = ?", v, v); label: return v; label: v := @caughtexception; return null; catch org.springframework.dao.EmptyResultDataAccessException from label to label with label; } public org.apache.nifi.registry.db.entity.FlowSnapshotEntity getLatestSnapshot(java.lang.String) { java.lang.Throwable v; java.lang.Object[] v; org.apache.nifi.registry.db.mapper.FlowSnapshotEntityRowMapper v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.Object v; java.lang.String v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; label: v = v.; v = new org.apache.nifi.registry.db.mapper.FlowSnapshotEntityRowMapper; specialinvoke v.()>(); v = newarray (java.lang.Object)[1]; v[0] = v; v = virtualinvoke v.("SELECT * FROM FLOW_SNAPSHOT WHERE flow_id = ? ORDER BY version DESC LIMIT 1", v, v); label: return v; label: v := @caughtexception; return null; catch org.springframework.dao.EmptyResultDataAccessException from label to label with label; } public java.util.List getSnapshots(java.lang.String) { java.util.List v; java.lang.Object[] v; org.apache.nifi.registry.db.mapper.FlowSnapshotEntityRowMapper v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.String v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v = newarray (java.lang.Object)[1]; v[0] = v; v = v.; v = new org.apache.nifi.registry.db.mapper.FlowSnapshotEntityRowMapper; specialinvoke v.()>(); v = virtualinvoke v.("SELECT fs.flow_id, fs.version, fs.created, fs.created_by, fs.comments FROM FLOW_SNAPSHOT fs, FLOW f, BUCKET_ITEM item WHERE item.id = f.id AND f.id = ? AND f.id = fs.flow_id", v, v); return v; } public void deleteFlowSnapshot(org.apache.nifi.registry.db.entity.FlowSnapshotEntity) { java.lang.Object[] v; org.apache.nifi.registry.db.DatabaseMetadataService v; org.apache.nifi.registry.db.entity.FlowSnapshotEntity v; java.lang.String v; java.lang.Integer v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: org.apache.nifi.registry.db.entity.FlowSnapshotEntity; v = v.; v = newarray (java.lang.Object)[2]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; virtualinvoke v.("DELETE FROM FLOW_SNAPSHOT WHERE flow_id = ? AND version = ?", v); return; } public org.apache.nifi.registry.db.entity.BundleEntity createBundle(org.apache.nifi.registry.db.entity.BundleEntity) { java.lang.Object[] v, v; java.util.Date v, v; org.springframework.jdbc.core.JdbcTemplate v, v; org.apache.nifi.registry.db.entity.BucketItemEntityType v; org.apache.nifi.registry.db.entity.BundleEntity v; org.apache.nifi.registry.extension.bundle.BundleType v; java.lang.String v, v, v, v, v, v, v, v, v, v; org.apache.nifi.registry.db.DatabaseMetadataService v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: org.apache.nifi.registry.db.entity.BundleEntity; v = v.; v = newarray (java.lang.Object)[7]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; v = virtualinvoke v.(); v[3] = v; v = virtualinvoke v.(); v[4] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v[5] = v; v = virtualinvoke v.(); v[6] = v; virtualinvoke v.("INSERT INTO BUCKET_ITEM (ID, NAME, DESCRIPTION, CREATED, MODIFIED, ITEM_TYPE, BUCKET_ID) VALUES (?, ?, ?, ?, ?, ?, ?)", v); v = v.; v = newarray (java.lang.Object)[5]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v[2] = v; v = virtualinvoke v.(); v[3] = v; v = virtualinvoke v.(); v[4] = v; virtualinvoke v.("INSERT INTO BUNDLE (ID, BUCKET_ID, BUNDLE_TYPE, GROUP_ID, ARTIFACT_ID) VALUES (?, ?, ?, ?, ?)", v); return v; } public org.apache.nifi.registry.db.entity.BundleEntity getBundle(java.lang.String) { java.lang.Throwable v; java.lang.Object[] v; long v; org.springframework.jdbc.core.JdbcTemplate v; java.lang.Long v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.Object v; java.lang.StringBuilder v; java.lang.String v, v; org.apache.nifi.registry.db.mapper.BundleEntityRowMapper v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; specialinvoke v.(java.lang.String)>("SELECT item.id as ID,item.name as NAME, item.description as DESCRIPTION, item.created as CREATED, item.modified as MODIFIED, eb.bundle_type as BUNDLE_TYPE, eb.group_id as GROUP_ID, eb.artifact_id as ARTIFACT_ID, b.id as BUCKET_ID, b.name as BUCKET_NAME FROM BUNDLE eb, BUCKET_ITEM item,BUCKET b WHERE eb.id = item.id AND item.bucket_id = b.id"); label: v = v.; v = dynamicinvoke "makeConcatWithConstants" () (" AND eb.id = ?"); v = new org.apache.nifi.registry.db.mapper.BundleEntityRowMapper; specialinvoke v.()>(); v = newarray (java.lang.Object)[1]; v[0] = v; v = virtualinvoke v.(v, v, v); v = specialinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: return v; label: v := @caughtexception; return null; catch org.springframework.dao.EmptyResultDataAccessException from label to label with label; } public org.apache.nifi.registry.db.entity.BundleEntity getBundle(java.lang.String, java.lang.String, java.lang.String) { java.lang.Throwable v; java.lang.Object[] v; long v; org.springframework.jdbc.core.JdbcTemplate v; java.lang.Long v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.Object v; java.lang.StringBuilder v; java.lang.String v, v, v, v, v; org.apache.nifi.registry.db.mapper.BundleEntityRowMapper v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.(java.lang.String)>("SELECT item.id as ID,item.name as NAME, item.description as DESCRIPTION, item.created as CREATED, item.modified as MODIFIED, eb.bundle_type as BUNDLE_TYPE, eb.group_id as GROUP_ID, eb.artifact_id as ARTIFACT_ID, b.id as BUCKET_ID, b.name as BUCKET_NAME FROM BUNDLE eb, BUCKET_ITEM item,BUCKET b WHERE eb.id = item.id AND item.bucket_id = b.id"); label: v = v.; v = dynamicinvoke "makeConcatWithConstants" () (" AND eb.bucket_id = ? AND eb.group_id = ? AND eb.artifact_id = ? "); v = new org.apache.nifi.registry.db.mapper.BundleEntityRowMapper; specialinvoke v.()>(); v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v[2] = v; v = virtualinvoke v.(v, v, v); v = virtualinvoke v.(); v = specialinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: return v; label: v := @caughtexception; return null; catch org.springframework.dao.EmptyResultDataAccessException from label to label with label; } public java.util.List getBundles(java.util.Set, org.apache.nifi.registry.extension.bundle.BundleFilterParams) { java.lang.Object[] v; org.apache.nifi.registry.extension.bundle.BundleFilterParams v; java.util.ArrayList v; org.springframework.jdbc.core.JdbcTemplate v; java.lang.String v, v, v, v; boolean v, v, v, v; org.apache.nifi.registry.db.mapper.BundleEntityRowMapper v; java.util.Set v; java.util.List v, v, v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.StringBuilder v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.util.Set; v := @parameter: org.apache.nifi.registry.extension.bundle.BundleFilterParams; if v == null goto label; v = interfaceinvoke v.(); if v == 0 goto label; label: v = staticinvoke (); return v; label: v = new java.util.ArrayList; specialinvoke v.()>(); v = new java.lang.StringBuilder; specialinvoke v.(java.lang.String)>("SELECT item.id as ID, item.name as NAME, item.description as DESCRIPTION, item.created as CREATED, item.modified as MODIFIED, item.item_type as ITEM_TYPE, b.id as BUCKET_ID, b.name as BUCKET_NAME ,eb.bundle_type as BUNDLE_TYPE, eb.group_id as GROUP_ID, eb.artifact_id as ARTIFACT_ID FROM BUNDLE eb, BUCKET_ITEM item,BUCKET b WHERE item.id = eb.id AND b.id = item.bucket_id"); if v == null goto label; v = virtualinvoke v.(); v = staticinvoke (v); if v != 0 goto label; virtualinvoke v.(" AND b.name LIKE ? "); interfaceinvoke v.(v); label: v = virtualinvoke v.(); v = staticinvoke (v); if v != 0 goto label; virtualinvoke v.(" AND eb.group_id LIKE ? "); interfaceinvoke v.(v); label: v = virtualinvoke v.(); v = staticinvoke (v); if v != 0 goto label; virtualinvoke v.(" AND eb.artifact_id LIKE ? "); interfaceinvoke v.(v); label: virtualinvoke v.(" AND "); specialinvoke v.(v, "item.bucket_id", v); virtualinvoke v.("ORDER BY eb.group_id ASC, eb.artifact_id ASC"); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = new org.apache.nifi.registry.db.mapper.BundleEntityRowMapper; specialinvoke v.()>(); v = virtualinvoke v.(v, v, v); v = specialinvoke v.(v); return v; } public java.util.List getBundlesByBucket(java.lang.String) { java.lang.Object[] v; org.springframework.jdbc.core.JdbcTemplate v; java.util.List v, v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.StringBuilder v; java.lang.String v, v; org.apache.nifi.registry.db.mapper.BundleEntityRowMapper v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; specialinvoke v.(java.lang.String)>("SELECT item.id as ID,item.name as NAME, item.description as DESCRIPTION, item.created as CREATED, item.modified as MODIFIED, eb.bundle_type as BUNDLE_TYPE, eb.group_id as GROUP_ID, eb.artifact_id as ARTIFACT_ID, b.id as BUCKET_ID, b.name as BUCKET_NAME FROM BUNDLE eb, BUCKET_ITEM item,BUCKET b WHERE eb.id = item.id AND item.bucket_id = b.id"); v = v.; v = dynamicinvoke "makeConcatWithConstants" () (" AND b.id = ? ORDER BY eb.group_id ASC, eb.artifact_id ASC"); v = newarray (java.lang.Object)[1]; v[0] = v; v = new org.apache.nifi.registry.db.mapper.BundleEntityRowMapper; specialinvoke v.()>(); v = virtualinvoke v.(v, v, v); v = specialinvoke v.(v); return v; } public java.util.List getBundlesByBucketAndGroup(java.lang.String, java.lang.String) { java.lang.Object[] v; org.springframework.jdbc.core.JdbcTemplate v; java.util.List v, v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.StringBuilder v; java.lang.String v, v, v; org.apache.nifi.registry.db.mapper.BundleEntityRowMapper v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.(java.lang.String)>("SELECT item.id as ID,item.name as NAME, item.description as DESCRIPTION, item.created as CREATED, item.modified as MODIFIED, eb.bundle_type as BUNDLE_TYPE, eb.group_id as GROUP_ID, eb.artifact_id as ARTIFACT_ID, b.id as BUCKET_ID, b.name as BUCKET_NAME FROM BUNDLE eb, BUCKET_ITEM item,BUCKET b WHERE eb.id = item.id AND item.bucket_id = b.id"); v = v.; v = dynamicinvoke "makeConcatWithConstants" () (" AND b.id = ? AND eb.group_id = ? ORDER BY eb.group_id ASC, eb.artifact_id ASC"); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; v = new org.apache.nifi.registry.db.mapper.BundleEntityRowMapper; specialinvoke v.()>(); v = virtualinvoke v.(v, v, v); v = specialinvoke v.(v); return v; } private java.util.List populateVersionCounts(java.util.List) { java.util.Iterator v; long v; java.util.List v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.util.Map v; java.lang.Object v, v; java.lang.String v; boolean v, v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.util.List; v = interfaceinvoke v.(); if v != 0 goto label; v = specialinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: return v; } public void deleteBundle(org.apache.nifi.registry.db.entity.BundleEntity) { java.lang.String v; org.apache.nifi.registry.db.DatabaseMetadataService v; org.apache.nifi.registry.db.entity.BundleEntity v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: org.apache.nifi.registry.db.entity.BundleEntity; v = virtualinvoke v.(); virtualinvoke v.(v); return; } public void deleteBundle(java.lang.String) { java.lang.Object[] v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.String v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v = v.; v = newarray (java.lang.Object)[1]; v[0] = v; virtualinvoke v.("DELETE FROM BUCKET_ITEM WHERE id = ?", v); return; } public org.apache.nifi.registry.db.entity.BundleVersionEntity createBundleVersion(org.apache.nifi.registry.db.entity.BundleVersionEntity) { java.lang.Object[] v; java.util.Date v, v; long v; java.lang.Integer v; org.springframework.jdbc.core.JdbcTemplate v; byte v; java.lang.Long v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v; boolean v; org.apache.nifi.registry.db.entity.BundleVersionEntity v; org.apache.nifi.registry.db.DatabaseMetadataService v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: org.apache.nifi.registry.db.entity.BundleVersionEntity; v = v.; v = newarray (java.lang.Object)[17]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; v = virtualinvoke v.(); v[3] = v; v = virtualinvoke v.(); v[4] = v; v = virtualinvoke v.(); v[5] = v; v = virtualinvoke v.(); v[6] = v; v = virtualinvoke v.(); if v == 0 goto label; v = 1; goto label; label: v = 0; label: v = staticinvoke (v); v[7] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[8] = v; v = virtualinvoke v.(); v[9] = v; v = virtualinvoke v.(); v[10] = v; v = virtualinvoke v.(); v[11] = v; v = virtualinvoke v.(); v[12] = v; v = virtualinvoke v.(); v[13] = v; v = virtualinvoke v.(); v[14] = v; v = virtualinvoke v.(); v[15] = v; v = virtualinvoke v.(); v[16] = v; virtualinvoke v.("INSERT INTO BUNDLE_VERSION (ID, BUNDLE_ID, VERSION, CREATED, CREATED_BY, DESCRIPTION, SHA_256_HEX, SHA_256_SUPPLIED,CONTENT_SIZE, SYSTEM_API_VERSION, BUILD_TOOL, BUILD_FLAGS, BUILD_BRANCH, BUILD_TAG, BUILD_REVISION, BUILT, BUILT_BY) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)", v); return v; } public org.apache.nifi.registry.db.entity.BundleVersionEntity getBundleVersion(java.lang.String, java.lang.String) { java.lang.Throwable v; java.lang.Object[] v; org.apache.nifi.registry.db.mapper.BundleVersionEntityRowMapper v; org.springframework.jdbc.core.JdbcTemplate v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.Object v; java.lang.String v, v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v := @parameter: java.lang.String; label: v = v.; v = new org.apache.nifi.registry.db.mapper.BundleVersionEntityRowMapper; specialinvoke v.()>(); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; v = virtualinvoke v.("SELECT ebv.id AS ID,ebv.bundle_id AS BUNDLE_ID, ebv.version AS VERSION, ebv.created AS CREATED, ebv.created_by AS CREATED_BY, ebv.description AS DESCRIPTION, ebv.sha_256_hex AS SHA_256_HEX, ebv.sha_256_supplied AS SHA_256_SUPPLIED ,ebv.content_size AS CONTENT_SIZE, ebv.system_api_version AS SYSTEM_API_VERSION, ebv.build_tool AS BUILD_TOOL, ebv.build_flags AS BUILD_FLAGS, ebv.build_branch AS BUILD_BRANCH, ebv.build_tag AS BUILD_TAG, ebv.build_revision AS BUILD_REVISION, ebv.built AS BUILT, ebv.built_by AS BUILT_BY, eb.bucket_id AS BUCKET_ID, eb.group_id AS GROUP_ID, eb.artifact_id AS ARTIFACT_ID FROM BUNDLE eb, BUNDLE_VERSION ebv WHERE eb.id = ebv.bundle_id AND ebv.bundle_id = ? AND ebv.version = ?", v, v); label: return v; label: v := @caughtexception; return null; catch org.springframework.dao.EmptyResultDataAccessException from label to label with label; } public org.apache.nifi.registry.db.entity.BundleVersionEntity getBundleVersion(java.lang.String, java.lang.String, java.lang.String, java.lang.String) { java.lang.Throwable v; java.lang.Object[] v; org.apache.nifi.registry.db.mapper.BundleVersionEntityRowMapper v; org.springframework.jdbc.core.JdbcTemplate v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.Object v; java.lang.String v, v, v, v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; label: v = v.; v = new org.apache.nifi.registry.db.mapper.BundleVersionEntityRowMapper; specialinvoke v.()>(); v = newarray (java.lang.Object)[4]; v[0] = v; v[1] = v; v[2] = v; v[3] = v; v = virtualinvoke v.("SELECT ebv.id AS ID,ebv.bundle_id AS BUNDLE_ID, ebv.version AS VERSION, ebv.created AS CREATED, ebv.created_by AS CREATED_BY, ebv.description AS DESCRIPTION, ebv.sha_256_hex AS SHA_256_HEX, ebv.sha_256_supplied AS SHA_256_SUPPLIED ,ebv.content_size AS CONTENT_SIZE, ebv.system_api_version AS SYSTEM_API_VERSION, ebv.build_tool AS BUILD_TOOL, ebv.build_flags AS BUILD_FLAGS, ebv.build_branch AS BUILD_BRANCH, ebv.build_tag AS BUILD_TAG, ebv.build_revision AS BUILD_REVISION, ebv.built AS BUILT, ebv.built_by AS BUILT_BY, eb.bucket_id AS BUCKET_ID, eb.group_id AS GROUP_ID, eb.artifact_id AS ARTIFACT_ID FROM BUNDLE eb, BUNDLE_VERSION ebv WHERE eb.id = ebv.bundle_id AND eb.bucket_id = ? AND eb.group_id = ? AND eb.artifact_id = ? AND ebv.version = ?", v, v); label: return v; label: v := @caughtexception; return null; catch org.springframework.dao.EmptyResultDataAccessException from label to label with label; } public java.util.List getBundleVersions(java.util.Set, org.apache.nifi.registry.extension.bundle.BundleVersionFilterParams) { java.lang.Object[] v; java.util.ArrayList v; org.springframework.jdbc.core.JdbcTemplate v; java.lang.String v, v, v, v; boolean v, v, v, v; java.util.Set v; org.apache.nifi.registry.db.mapper.BundleVersionEntityRowMapper v; java.util.List v, v; org.apache.nifi.registry.db.DatabaseMetadataService v; org.apache.nifi.registry.extension.bundle.BundleVersionFilterParams v; java.lang.StringBuilder v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.util.Set; v := @parameter: org.apache.nifi.registry.extension.bundle.BundleVersionFilterParams; if v == null goto label; v = interfaceinvoke v.(); if v == 0 goto label; label: v = staticinvoke (); return v; label: v = new java.util.ArrayList; specialinvoke v.()>(); v = new java.lang.StringBuilder; specialinvoke v.(java.lang.String)>("SELECT ebv.id AS ID,ebv.bundle_id AS BUNDLE_ID, ebv.version AS VERSION, ebv.created AS CREATED, ebv.created_by AS CREATED_BY, ebv.description AS DESCRIPTION, ebv.sha_256_hex AS SHA_256_HEX, ebv.sha_256_supplied AS SHA_256_SUPPLIED ,ebv.content_size AS CONTENT_SIZE, ebv.system_api_version AS SYSTEM_API_VERSION, ebv.build_tool AS BUILD_TOOL, ebv.build_flags AS BUILD_FLAGS, ebv.build_branch AS BUILD_BRANCH, ebv.build_tag AS BUILD_TAG, ebv.build_revision AS BUILD_REVISION, ebv.built AS BUILT, ebv.built_by AS BUILT_BY, eb.bucket_id AS BUCKET_ID, eb.group_id AS GROUP_ID, eb.artifact_id AS ARTIFACT_ID FROM BUNDLE eb, BUNDLE_VERSION ebv WHERE eb.id = ebv.bundle_id "); if v == null goto label; v = virtualinvoke v.(); v = staticinvoke (v); if v != 0 goto label; virtualinvoke v.(" AND eb.group_id LIKE ? "); interfaceinvoke v.(v); label: v = virtualinvoke v.(); v = staticinvoke (v); if v != 0 goto label; virtualinvoke v.(" AND eb.artifact_id LIKE ? "); interfaceinvoke v.(v); label: v = virtualinvoke v.(); v = staticinvoke (v); if v != 0 goto label; virtualinvoke v.(" AND ebv.version LIKE ? "); interfaceinvoke v.(v); label: virtualinvoke v.(" AND "); specialinvoke v.(v, "eb.bucket_id", v); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = new org.apache.nifi.registry.db.mapper.BundleVersionEntityRowMapper; specialinvoke v.()>(); v = virtualinvoke v.(v, v, v); return v; } private void addIdentifiersInClause(java.lang.StringBuilder, java.lang.String, java.util.Set) { org.apache.nifi.registry.db.DatabaseMetadataService v; int v, v; java.util.Set v; java.lang.StringBuilder v, v; java.lang.String v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.StringBuilder; v := @parameter: java.lang.String; v := @parameter: java.util.Set; v = virtualinvoke v.(v); virtualinvoke v.(" IN ("); v = 0; label: v = interfaceinvoke v.(); if v >= v goto label; if v <= 0 goto label; virtualinvoke v.(", "); label: virtualinvoke v.("?"); v = v + 1; goto label; label: virtualinvoke v.(") "); return; } public java.util.List getBundleVersions(java.lang.String) { java.util.List v; java.lang.Object[] v; org.apache.nifi.registry.db.DatabaseMetadataService v; org.apache.nifi.registry.db.mapper.BundleVersionEntityRowMapper v; java.lang.String v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v = v.; v = newarray (java.lang.Object)[1]; v[0] = v; v = new org.apache.nifi.registry.db.mapper.BundleVersionEntityRowMapper; specialinvoke v.()>(); v = virtualinvoke v.("SELECT ebv.id AS ID,ebv.bundle_id AS BUNDLE_ID, ebv.version AS VERSION, ebv.created AS CREATED, ebv.created_by AS CREATED_BY, ebv.description AS DESCRIPTION, ebv.sha_256_hex AS SHA_256_HEX, ebv.sha_256_supplied AS SHA_256_SUPPLIED ,ebv.content_size AS CONTENT_SIZE, ebv.system_api_version AS SYSTEM_API_VERSION, ebv.build_tool AS BUILD_TOOL, ebv.build_flags AS BUILD_FLAGS, ebv.build_branch AS BUILD_BRANCH, ebv.build_tag AS BUILD_TAG, ebv.build_revision AS BUILD_REVISION, ebv.built AS BUILT, ebv.built_by AS BUILT_BY, eb.bucket_id AS BUCKET_ID, eb.group_id AS GROUP_ID, eb.artifact_id AS ARTIFACT_ID FROM BUNDLE eb, BUNDLE_VERSION ebv WHERE eb.id = ebv.bundle_id AND ebv.bundle_id = ?", v, v); return v; } public java.util.List getBundleVersions(java.lang.String, java.lang.String, java.lang.String) { java.lang.Object[] v; org.apache.nifi.registry.db.mapper.BundleVersionEntityRowMapper v; org.springframework.jdbc.core.JdbcTemplate v; java.util.List v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.String v, v, v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v[2] = v; v = v.; v = new org.apache.nifi.registry.db.mapper.BundleVersionEntityRowMapper; specialinvoke v.()>(); v = virtualinvoke v.("SELECT ebv.id AS ID,ebv.bundle_id AS BUNDLE_ID, ebv.version AS VERSION, ebv.created AS CREATED, ebv.created_by AS CREATED_BY, ebv.description AS DESCRIPTION, ebv.sha_256_hex AS SHA_256_HEX, ebv.sha_256_supplied AS SHA_256_SUPPLIED ,ebv.content_size AS CONTENT_SIZE, ebv.system_api_version AS SYSTEM_API_VERSION, ebv.build_tool AS BUILD_TOOL, ebv.build_flags AS BUILD_FLAGS, ebv.build_branch AS BUILD_BRANCH, ebv.build_tag AS BUILD_TAG, ebv.build_revision AS BUILD_REVISION, ebv.built AS BUILT, ebv.built_by AS BUILT_BY, eb.bucket_id AS BUCKET_ID, eb.group_id AS GROUP_ID, eb.artifact_id AS ARTIFACT_ID FROM BUNDLE eb, BUNDLE_VERSION ebv WHERE eb.id = ebv.bundle_id AND eb.bucket_id = ? AND eb.group_id = ? AND eb.artifact_id = ? ", v, v); return v; } public java.util.List getBundleVersionsGlobal(java.lang.String, java.lang.String, java.lang.String) { java.lang.Object[] v; org.apache.nifi.registry.db.mapper.BundleVersionEntityRowMapper v; org.springframework.jdbc.core.JdbcTemplate v; java.util.List v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.String v, v, v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v[2] = v; v = v.; v = new org.apache.nifi.registry.db.mapper.BundleVersionEntityRowMapper; specialinvoke v.()>(); v = virtualinvoke v.("SELECT ebv.id AS ID,ebv.bundle_id AS BUNDLE_ID, ebv.version AS VERSION, ebv.created AS CREATED, ebv.created_by AS CREATED_BY, ebv.description AS DESCRIPTION, ebv.sha_256_hex AS SHA_256_HEX, ebv.sha_256_supplied AS SHA_256_SUPPLIED ,ebv.content_size AS CONTENT_SIZE, ebv.system_api_version AS SYSTEM_API_VERSION, ebv.build_tool AS BUILD_TOOL, ebv.build_flags AS BUILD_FLAGS, ebv.build_branch AS BUILD_BRANCH, ebv.build_tag AS BUILD_TAG, ebv.build_revision AS BUILD_REVISION, ebv.built AS BUILT, ebv.built_by AS BUILT_BY, eb.bucket_id AS BUCKET_ID, eb.group_id AS GROUP_ID, eb.artifact_id AS ARTIFACT_ID FROM BUNDLE eb, BUNDLE_VERSION ebv WHERE eb.id = ebv.bundle_id AND eb.group_id = ? AND eb.artifact_id = ? AND ebv.version = ?", v, v); return v; } public void deleteBundleVersion(org.apache.nifi.registry.db.entity.BundleVersionEntity) { java.lang.String v; org.apache.nifi.registry.db.DatabaseMetadataService v; org.apache.nifi.registry.db.entity.BundleVersionEntity v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: org.apache.nifi.registry.db.entity.BundleVersionEntity; v = virtualinvoke v.(); virtualinvoke v.(v); return; } public void deleteBundleVersion(java.lang.String) { java.lang.Object[] v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.String v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v = v.; v = newarray (java.lang.Object)[1]; v[0] = v; virtualinvoke v.("DELETE FROM BUNDLE_VERSION WHERE id = ?", v); return; } public org.apache.nifi.registry.db.entity.BundleVersionDependencyEntity createDependency(org.apache.nifi.registry.db.entity.BundleVersionDependencyEntity) { org.apache.nifi.registry.db.entity.BundleVersionDependencyEntity v; java.lang.Object[] v; org.springframework.jdbc.core.JdbcTemplate v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.String v, v, v, v, v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: org.apache.nifi.registry.db.entity.BundleVersionDependencyEntity; v = v.; v = newarray (java.lang.Object)[5]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; v = virtualinvoke v.(); v[3] = v; v = virtualinvoke v.(); v[4] = v; virtualinvoke v.("INSERT INTO BUNDLE_VERSION_DEPENDENCY (ID, BUNDLE_VERSION_ID, GROUP_ID, ARTIFACT_ID, VERSION ) VALUES (?, ?, ?, ?, ?)", v); return v; } public java.util.List getDependenciesForBundleVersion(java.lang.String) { java.util.List v; java.lang.Object[] v; org.apache.nifi.registry.db.mapper.BundleVersionDependencyEntityRowMapper v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.String v; org.springframework.jdbc.core.JdbcTemplate v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v = newarray (java.lang.Object)[1]; v[0] = v; v = v.; v = new org.apache.nifi.registry.db.mapper.BundleVersionDependencyEntityRowMapper; specialinvoke v.()>(); v = virtualinvoke v.("SELECT * FROM BUNDLE_VERSION_DEPENDENCY WHERE bundle_version_id = ?", v, v); return v; } public org.apache.nifi.registry.db.entity.ExtensionEntity createExtension(org.apache.nifi.registry.db.entity.ExtensionEntity) { java.lang.Object[] v, v; java.lang.Integer v; org.springframework.jdbc.core.JdbcTemplate v, v; org.apache.nifi.extension.manifest.ExtensionType v; byte v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; boolean v, v; org.apache.nifi.registry.db.entity.ExtensionEntity v; java.util.Iterator v; java.util.Set v, v, v; java.util.function.Consumer v, v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.Object v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: org.apache.nifi.registry.db.entity.ExtensionEntity; v = v.; v = newarray (java.lang.Object)[8]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; v = virtualinvoke v.(); v[3] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v[4] = v; v = virtualinvoke v.(); v[5] = v; v = virtualinvoke v.(); v[6] = v; v = virtualinvoke v.(); if v == null goto label; v = 1; goto label; label: v = 0; label: v = staticinvoke (v); v[7] = v; virtualinvoke v.("INSERT INTO EXTENSION (ID, BUNDLE_VERSION_ID, NAME, DISPLAY_NAME, TYPE, CONTENT, ADDITIONAL_DETAILS, HAS_ADDITIONAL_DETAILS ) VALUES (?, ?, ?, ?, ?, ?, ?, ?)", v); v = virtualinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = newarray (java.lang.Object)[2]; v = virtualinvoke v.(); v[0] = v; v[1] = v; virtualinvoke v.("INSERT INTO EXTENSION_TAG (EXTENSION_ID, TAG) VALUES (?, ?);", v); goto label; label: v = virtualinvoke v.(); if v == null goto label; v = staticinvoke (v); interfaceinvoke v.(v); label: v = virtualinvoke v.(); if v == null goto label; v = staticinvoke (v); interfaceinvoke v.(v); label: return v; } public org.apache.nifi.registry.db.entity.ExtensionEntity getExtensionById(java.lang.String) { java.lang.Throwable v; java.lang.Object[] v; org.apache.nifi.registry.db.mapper.ExtensionEntityRowMapper v; org.springframework.jdbc.core.JdbcTemplate v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.Object v; java.lang.String v, v, v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u AND e.id = ?"); label: v = v.; v = new org.apache.nifi.registry.db.mapper.ExtensionEntityRowMapper; specialinvoke v.()>(); v = newarray (java.lang.Object)[1]; v[0] = v; v = virtualinvoke v.(v, v, v); label: return v; label: v := @caughtexception; return null; catch org.springframework.dao.EmptyResultDataAccessException from label to label with label; } public org.apache.nifi.registry.db.entity.ExtensionEntity getExtensionByName(java.lang.String, java.lang.String) { java.lang.Throwable v; java.lang.Object[] v; org.apache.nifi.registry.db.mapper.ExtensionEntityRowMapper v; org.springframework.jdbc.core.JdbcTemplate v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.Object v; java.lang.String v, v, v, v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u AND e.bundle_version_id = ? AND e.name = ?"); label: v = v.; v = new org.apache.nifi.registry.db.mapper.ExtensionEntityRowMapper; specialinvoke v.()>(); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; v = virtualinvoke v.(v, v, v); label: return v; label: v := @caughtexception; return null; catch org.springframework.dao.EmptyResultDataAccessException from label to label with label; } public org.apache.nifi.registry.db.entity.ExtensionAdditionalDetailsEntity getExtensionAdditionalDetails(java.lang.String, java.lang.String) { java.lang.Throwable v; java.lang.Object[] v; org.springframework.jdbc.core.JdbcTemplate v; org.apache.nifi.registry.db.DatabaseMetadataService v; org.springframework.jdbc.core.RowMapper v; java.lang.Object v; java.lang.String v, v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.lang.String; v := @parameter: java.lang.String; label: v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; v = v.; v = staticinvoke (); v = virtualinvoke v.("SELECT id, additional_details FROM EXTENSION WHERE bundle_version_id = ? AND name = ?", v, v); label: return v; label: v := @caughtexception; return null; catch org.springframework.dao.EmptyResultDataAccessException from label to label with label; } public java.util.List getExtensions(java.util.Set, org.apache.nifi.extension.ExtensionFilterParams) { java.lang.Object[] v; org.apache.nifi.extension.ExtensionFilterParams v; org.apache.nifi.registry.db.mapper.ExtensionEntityRowMapper v; java.util.ArrayList v; org.springframework.jdbc.core.JdbcTemplate v; org.apache.nifi.extension.manifest.ExtensionType v; org.apache.nifi.registry.extension.bundle.BundleType v; java.lang.String v, v, v, v, v, v; boolean v, v, v, v; java.util.Iterator v; java.util.Set v, v; java.util.List v, v; org.apache.nifi.registry.db.DatabaseMetadataService v; java.lang.Object v; java.lang.StringBuilder v, v; v := @this: org.apache.nifi.registry.db.DatabaseMetadataService; v := @parameter: java.util.Set; v := @parameter: org.apache.nifi.extension.ExtensionFilterParams; if v == null goto label; v = interfaceinvoke v.(); if v == 0 goto label; label: v = staticinvoke (); return v; label: v = new java.util.ArrayList; specialinvoke v.()>(); v = new java.lang.StringBuilder; v = ; specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(" AND "); specialinvoke v.(v, "eb.bucket_id", v); interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); if v == null goto label; virtualinvoke v.(" AND eb.bundle_type = ?"); v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = virtualinvoke v.(); if v == null goto label; virtualinvoke v.(" AND e.type = ?"); v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = virtualinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(" AND e.id IN ("); virtualinvoke v.(" SELECT et.extension_id FROM EXTENSION_TAG et WHERE "); v = 1; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); if v != 0 goto label; virtualinvoke v.(" OR "); label: virtualinvoke v.(" et.tag = ? "); v = virtualinvoke v.