// wurblet generated by Wurbelizer 25.7.0.0, see https://wurbelizer.org
   
   package org.tentackle.persist.wurblet;
   
   import org.tentackle.wurblet.*;
   import org.tentackle.buildsupport.*;
   import java.util.*;
   import java.io.*;
   import org.tentackle.common.*;
  import org.wurbelizer.wurbel.*;
  import org.tentackle.sql.*;
  import org.tentackle.model.*;
  import org.wurbelizer.wurblet.*;
  
  /**
   * <strong>({@code @wurblet})</strong> Generate code to delete low-level persistent objects.
   * <p>
   * usage:<br>
   * &#064;wurblet &lt;tag&gt; DbDeleteBy [--private] [--append=&lt;sqltext&gt;] [--classvar=&lt;classvariables&gt;] &lt;expression&gt;
   * <p>
   * arguments:
   * <ul>
   * <li><em>--private:</em> makes the method private (default is public).</li>
   * <li><em>--append=&lt;sqltext&gt;:</em> appends an sql-string.</li>
   * <li><em>--classvar=&lt;classvariables&gt;:</em> reference to classvariables, if pick the statement-IDs from there.</li>
   * <li><em>&lt;expression&gt;:</em> see {@link WurbletArgumentParser}.</li>
   * </ul>
   * For more options, see {@link DbModelWurblet}.
   */
  public class DbDeleteBy extends DbModelWurblet {
  
    @Override
    public void run() throws WurbelException {
      super.run();
      try {
        wurbel();
      }
      catch (Throwable t) {
        if (t instanceof WurbelException) {
          throw (WurbelException) t;
        }
        throw new WurbelException("wurblet " + this + " failed", t);
      }
    }
  
    // ----------------- begin wurblet code -----------------
  
    private void wurbel() throws WurbelException, ModelException {
  
      assertNoOptionalArguments();    // the prepared statement is cached, i.e. the SQL text must be fixed
  
      String className = getClassName();
      String methodName = getMethodName();
  
      String  classVar    = null;
      String  append      = null;
      String  scope       = "public";
  
      for (String arg: getOptionArgs())  {
        if (arg.equals("private")) {
          scope = "private";
          setRemote(false);
        }
        else if (arg.startsWith("append=")) {
          append = arg.substring(7);
        }
        else if (arg.startsWith("classvar="))  {
          classVar = arg.substring(9);
        }
      }
  
      if (classVar == null) {
        classVar = "";
      }
      else  {
        classVar += ".";    // add dot to access class var
      }
  
      String params = buildMethodParameters();
      String iparms = buildInvocationParameters();
      String statementId = createStatementId();
  
      out.print(source[0]); // 53:2 = "  "
      out.print(scope);
      out.print(source[1]); // 54:11 = " int "
      out.print(methodName);
      out.print(source[2]); // 54:30 = "("
      out.print(params);
      out.print(source[3]); // 54:41 = ") {"
      if (isRemote()) {
        // create includes
        RemoteIncludes genInc = new RemoteIncludes(this);
        PrintStream implOut   = genInc.getImplementationStream();
        PrintStream remoteOut = genInc.getInterfaceStream();
        out.print(source[4]); // 61:2 = "    if (getSession().isRemote())  {"
        remoteOut.print(source[5]); // 63:16 = "  int "
        remoteOut.print(methodName);
        remoteOut.print(source[6]); // 64:20 = "("
        remoteOut.print(params);
       remoteOut.print(source[7]); // 64:31 = ");"
       implOut.print(source[8]); // 65:14 = "  @Override  public int "
       implOut.print(methodName);
       implOut.print(source[9]); // 68:27 = "("
       implOut.print(params);
       implOut.print(source[10]); // 68:38 = ") {"
       implOut.print(source[11]); // 69:14 = "    return dbObject."
       implOut.print(methodName);
       implOut.print(source[12]); // 70:34 = "("
       implOut.print(iparms);
       implOut.print(source[13]); // 70:45 = ");  }"
       out.print(source[14]); // 72:6 = "      return getRemoteDelegate()."
       out.print(methodName);
       out.print(source[15]); // 73:47 = "("
       out.print(iparms);
       out.print(source[16]); // 73:58 = ");    }    // else: local mode"
     } // end if remote
      out.print(source[17]); // 78:2 = "    PreparedStatementWrapper st = getPre..."
      out.print(classVar);
      out.print(statementId);
      out.print(source[18]); // 79:82 = ",      b -> {        StringBuilder sql..."
     if (getEntity().getSuperEntity() != null && getEntity().getHierarchyInheritanceType() == InheritanceType.SINGLE) {
       out.print(source[19]); // genwhere.incl:3:2 = "        sql.append(getSqlClassIdConditio..."
     }
 
     boolean andPrepended = false;
     if (getContextAttribute() != null) {
         andPrepended = true;
         out.print(source[20]); // genwhere.incl:11:2 = "        sql.append(Backend.SQL_AND)    ..."
         out.print(getColumnNameConstant(getContextAttribute(), 0));
         out.print(source[21]); // genwhere.incl:13:70 = ")           .append(Backend.SQL_EQUAL_P..."
     }
 
     boolean needParentheses = false;
 
     if (!getExpressionArguments().isEmpty()) {
       needParentheses = getExpression().needParenthesesAfterAndOperator();
       if (andPrepended || needParentheses) {
         out.print(source[22]); // genwhere.incl:23:2 = "        sql.append(Backend.SQL_AND).appe..."
       }
       else {
         out.print(source[23]); // genwhere.incl:28:2 = "        sql.append(Backend.SQL_AND);"
         if (needParentheses && getEntity().getHierarchyInheritanceType() == InheritanceType.SINGLE) {
           out.print(source[24]); // genwhere.incl:32:2 = "        if (classIdRequired) {         ..."
         }
       }
 
       // generate the where expressions
       String code = getExpression().toCode(new WhereClauseGenerator(this));
       out.print(StringHelper.trimRight(code, '\n'));
       out.print(source[25]); // genwhere.incl:43:38 = ""
 
       if (andPrepended || needParentheses) {
         out.print(source[26]); // genwhere.incl:47:2 = "        sql.append(Backend.SQL_RIGHT_PAR..."
       }
       else if (needParentheses && getEntity().getHierarchyInheritanceType() == InheritanceType.SINGLE) {
         out.print(source[27]); // genwhere.incl:52:2 = "        if (classIdRequired) {         ..."
       }
 
       if (isWithOptionalArguments()) {
         // skipped conditions may leave empty sub-expressions and dangling operators behind.
         // must be applied before any trailing clause is appended.
         out.print(source[28]); // genwhere.incl:62:2 = "        b.reduceSql(sql);"
       }
     }
 
     String orderByStr = createOrderBy();
     if (orderByStr != null) {
       out.print(source[29]); // genwhere.incl:70:2 = "        sql.append(Backend.SQL_ORDERBY)..."
       out.print(orderByStr);
       out.print(source[30]); // genwhere.incl:72:25 = ";"
     }
     if (append != null) {
       out.print(source[31]); // 85:2 = "        sql.append("
       out.print(append);
       out.print(source[32]); // 86:29 = ");"
     }
     out.print(source[33]); // 89:2 = "        return sql.toString();      } ..."
     if (isWithJoins()) {
       out.print(createJoinSetPars());
     }
 
     if (getContextAttribute() != null) {
       out.print(source[34]); // gensetpar.incl:7:2 = "    st."
       out.print(createJdbcSetterName(getContextAttribute().getDataType()));
       out.print(source[35]); // gensetpar.incl:8:68 = "(ndx++, "
       out.print(getContextAttribute().getName());
       out.print(source[36]); // gensetpar.incl:8:111 = ");"
     }
     for (WurbletArgument par: getMethodArguments())  {
       // the values of the EXISTS clause are set only if the clause is part of the query
       String clauseCondition = par.getExistsArguments() == null ? null :
                                  createOptionalCondition(par.getExistsArguments());
       String indent = clauseCondition == null ? "" : "  ";
       if (par.isPath()) {
         // check for additional value-args in relations
         Set<Relation> existsRels = par.getExistsRelations();
         boolean withValueArgs = false;
         if (existsRels != null) {
           for (Relation rel: existsRels) {
             List<MethodArgument> methodArgs = rel.getMethodArgs();
             for (MethodArgument methodArg: methodArgs.subList(1, methodArgs.size())) {
               if (methodArg.isValue()) {
                 withValueArgs = true;
               }
             }
           }
         }
         if (withValueArgs) {
           if (clauseCondition != null) {
             out.print(source[37]); // gensetpar.incl:32:2 = "    if ("
             out.print(clauseCondition);
             out.print(source[38]); // gensetpar.incl:33:27 = ") {"
           }
           for (Relation rel: existsRels) {
             List<MethodArgument> methodArgs = rel.getMethodArgs();
             for (MethodArgument methodArg: methodArgs.subList(1, methodArgs.size())) {
               if (methodArg.isValue()) {
                 Attribute attr = methodArg.getForeignAttribute();
                 out.print(source[39]); // gensetpar.incl:41:2 = "    "
                 out.print(indent);
                 out.print(createWhereSetPars(attr, attr.toMethodArgument(methodArg.getValue())));
                 out.print(source[40]); // gensetpar.incl:42:87 = ";"
               }
             }
           }
           if (clauseCondition != null) {
             out.print(source[41]); // gensetpar.incl:48:2 = "    }"
           }
         }
       }
 
       if (!par.isValueLiterally()) {
         // the parameters of an optional condition are set only if the condition is part of the query
         String optCondition = par.isOptional() ? par.getOptionalName() : null;
         indent = optCondition == null ? "" : "  ";
         if (optCondition != null) {
           out.print(source[42]); // gensetpar.incl:60:2 = "    if ("
           out.print(optCondition);
           out.print(source[43]); // gensetpar.incl:61:24 = ") {"
         }
         out.print(source[44]); // gensetpar.incl:64:2 = "    "
         out.print(indent);
         out.print(createWhereSetPars(par));
         out.print(source[45]); // gensetpar.incl:65:41 = ";"
         if (optCondition != null) {
           out.print(source[46]); // gensetpar.incl:68:2 = "    }"
         }
       }
     }
     out.print(source[47]); // 94:38 = "    return st.executeUpdate();  }"
     if (classVar.isEmpty()) {
       out.print(source[48]); // 99:2 = "  private static final StatementId "
       out.print(statementId);
       out.print(source[49]); // 101:50 = " = new StatementId();"
     }
   }
 
   // ----------------- end wurblet code -----------------
 
   @Override
   public String process(String code) {
     if (isWithOptionalArguments()) {
       // the last set parameter may be skipped at runtime: keep all increments
       return code;
     }
     int ref = code.lastIndexOf("ndx");
     int pos = code.lastIndexOf("(ndx++,");
     if (pos >= 0 && ref == pos + 1) {
       // remove unnecessary last ++
       code = code.substring(0, pos + 4) + code.substring(pos + 6);
     }
     else {
       // remove unnecessary last ndx +=
       pos = code.lastIndexOf("ndx += st.set(");   // ndx += st.set(DT_POSITION3D, ndx, dropPosition, false, null);
       if (pos >= 0 && ref > pos) {
         code = code.substring(0, pos) + code.substring(pos + 7);
       }
       else {
         pos = code.lastIndexOf(", ndx++, ");   // st.set(SqlType....., ndx++, value.get...)
         if (pos >= 0 && ref > pos) {
           code = code.substring(0, pos + 5) + code.substring(pos + 7);
         }
       }
     }
     return code;
   }
 }