package com.l7tech.server.audit;

import com.l7tech.server.jdbc.JdbcQueryingManager;
import java.util.Collections;
import javax.sql.DataSource;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.TransactionCallback;

class c implements TransactionCallback<String> {
   final String val$schema;
   final JdbcQueryingManager val$jdbcQueryingManager;
   final DataSource val$ds;

   c(b var1, String var2, JdbcQueryingManager var3, DataSource var4) {
      this.val$schema = var2;
      this.val$jdbcQueryingManager = var3;
      this.val$ds = var4;
   }

   public String doInTransaction(TransactionStatus var1) {
      int var6 = 0;
      int var3 = 0;

      while (this.val$schema.indexOf(";", var6) > 0) {
         var3 = var6 + 1;
         var6 = this.val$schema.indexOf(";", var6);
         String var4 = this.val$schema.substring(var3 - 1, var6);
         var6++;
         Object var5 = this.val$jdbcQueryingManager.performJdbcQuery(this.val$ds, var4, null, 2, Collections.emptyList());
         if (var5 instanceof String) {
            var1.setRollbackOnly();
            return (String)var5;
         }
      }

      return "";
   }
}