public interface Function
{
	void xFunc() throws java.sql.SQLException;
	default void xStep() throws java.sql.SQLException{}
	default void xFinal() throws java.sql.SQLException{}
	default void setBridge(Object bridge){}
}

public class AggregateBridge extends org.sqlite.Function.Aggregate implements Cloneable
{
    protected final Function function;

    public AggregateBridge(Function function)
    {
        super();
        this.function = function;
    }
    protected void xStep() throws java.sql.SQLException{
        function.xStep();
    }
    protected void xFinal() throws java.sql.SQLException{
        function.xFinal();
    }

    /** @see java.lang.Object#clone() */
    public Object clone() throws CloneNotSupportedException {
        new java.lang.Throwable().printStackTrace();
        Object ref=super.clone();
        function.setBridge(ref);
        return ref;
    }
    /**
     * Returns the number of arguments passed to the function. Can only be called from
     * <tt>xFunc()</tt>.
     */
    public int iargs() throws java.sql.SQLException
    {
        return super.args();
    }
    /**
     * Called by <tt>xFunc</tt> to return a value.
     *
     * @param value
     */
    public void iresult(byte[] value) throws java.sql.SQLException {
        super.result(value);
    }

    /**
     * Called by <tt>xFunc</tt> to return a value.
     *
     * @param value
     */
    public void iresult(double value) throws java.sql.SQLException {
        super.result(value);
    }

    /**
     * Called by <tt>xFunc</tt> to return a value.
     *
     * @param value
     */
    public void iresult(int value) throws java.sql.SQLException {
        super.result(value);
    }

    /**
     * Called by <tt>xFunc</tt> to return a value.
     *
     * @param value
     */
    public void iresult(long value) throws java.sql.SQLException {
        super.result(value);
    }

    /** Called by <tt>xFunc</tt> to return a value. */
    public void iresult() throws java.sql.SQLException {
        super.result();
    }

    /**
     * Called by <tt>xFunc</tt> to return a value.
     *
     * @param value
     */
    public void iresult(String value) throws java.sql.SQLException {
        super.result(value);
    }

    /**
     * Called by <tt>xFunc</tt> to throw an error.
     *
     * @param err
     */
    public void ierror(String err) throws java.sql.SQLException {
        super.error(err);
    }

    /**
     * Called by <tt>xFunc</tt> to access the value of an argument.
     *
     * @param arg
     */
    public String ivalue_text(int arg) throws java.sql.SQLException {
        return super.value_text(arg);
    }

    /**
     * Called by <tt>xFunc</tt> to access the value of an argument.
     *
     * @param arg
     */
    public byte[] ivalue_blob(int arg) throws java.sql.SQLException {
        return super.value_blob(arg);
    }

    /**
     * Called by <tt>xFunc</tt> to access the value of an argument.
     *
     * @param arg
     */
    public double ivalue_double(int arg) throws java.sql.SQLException {
        return super.value_double(arg);
    }

    /**
     * Called by <tt>xFunc</tt> to access the value of an argument.
     *
     * @param arg
     */
    public int ivalue_int(int arg) throws java.sql.SQLException {
        return super.value_int(arg);
    }

    /**
     * Called by <tt>xFunc</tt> to access the value of an argument.
     *
     * @param arg
     */
    public long ivalue_long(int arg) throws java.sql.SQLException {
        return super.value_long(arg);
    }

    /**
     * Called by <tt>xFunc</tt> to access the value of an argument.
     *
     * @param arg
     */
     public int ivalue_type(int arg) throws java.sql.SQLException {
         return super.value_type(arg);
    }
}

conn=sQLshellAPI.getCurrentlyVisibleShell().getConnection();

specs=sQLshellAPI.getCurrentlyVisibleShell().getDBMSInterface().getDatabaseSpecifics().orElse(null);

java.util.concurrent.atomic.AtomicInteger latch=null;

myFunc=new de.elbosso.db.spi.impl.sqlite.Function() {
			public void setBridge(Object bridge)
			{
				func=bridge;
			}
          protected void xStep() {
			if(latch==null)
				latch=new java.util.concurrent.atomic.AtomicInteger(0);
              latch.addAndGet(func.ivalue_int(0));
          }
          protected void xFinal() {
              func.iresult(latch.get());
			latch=null;
          }
      };
func=new de.elbosso.db.spi.impl.sqlite.AggregateBridge(myFunc);

specs.create("myFunc", func);