SQL-Aggregatfunktionen in SQLite als BeanShell-Scripts

vorhergehende Artikel in: Java Komponenten sQLshell
30.06.2024

Ich habe neulich über eine Möglichkeit berichtet, SQLite mittels der sQLshell und Beanshell-Skripten um SQL-Funktionen zu erweitern. In diesem Artikel versprach ich auch, über eine solche Möglichkeit für Aggregatfunktionen zu berichten.

Die Unterstützung von Aggregatfunktionen in SQLite mittels Beanshell-Skripten erwies sich eals ein wenig komplizierter. Ich musste dazu zunächst das Interface erweitern, über das die Funktionen implementiert werden:

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){}
}

Da SQLite, bzw. der JDBC-Treiber über die Klasse der Implementierung erkennt, ob die Funktion eine Aggregatfunktion ist, musste ich analog der im letzten Artikel vorgestellten Klasse Bridge eine parallele Implementierung für Aggregatfunktionen erstellen:

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); } }

Damit ist es nun möglich, auch Aggregatfunktionen mittels Beanshell-Skripten zu implementieren und in der SQLshell zu SQLite-Datenbanken hinzuzufügen:

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);

Hierbei ist es ganz wichtig, die Referenz auf die Bridge in der Methode setBridge zu aktualisieren, da bei Aggregatfunktionen für jede Zeile die Instanz der Aggregatfunktion geklont wird - und damit würde die im Skript angelegte nicht funktionieren - nur der in der jeweiligen Iteration erzeugte Clone funktioniert - daher auch die etwas seltsam anmutende Implementierung der methode clone in der Klasse AggregateBridge.

Artikel, die hierher verlinken

Collations für SQLite mittels BeanShell

11.08.2024

Ich habe neulich übere eine Möglichkeit berichtet, SQLite mittels der sQLshell und Beanshell-Skripten um SQL-Funktionen zu erweitern. Ich habe weitere Untersuchungen in dieser Richtung angestellt.

Alle Artikel rss Wochenübersicht Monatsübersicht Codeberg Repositories Mastodon Über mich home xmpp


Vor 5 Jahren hier im Blog

  • Ticketsysteme sind lebende Wesen

    29.03.2020

    Hier zunächst wieder eine Triggerwarnung: Dieser Artikel wird meine Meinung abbilden. es kann sein, dass sie dem einen oder anderen nicht gefällt - das ist mir aber egal. Und wenn hier irgendwelche Schneeflocken mitlesen, dann sind die selber schuld.

    Weiterlesen...

Neueste Artikel

  • Weitere Experimente mit dem Clifford-Attractor

    Ich berichtete hier bereits über Experimente mit dem Clifford-Attractor, allerdings war ich noch Experimente unter geringfügig geänderten Parametern schuldig...

    Weiterlesen
  • Neues Feature in meinem Static Site Generator: externe URLs

    Es wurde wieder einmal Zeit für ein neues Feature in meinem Static Site Generator mittels dessen ich ja auch meine Heimatseite im Zwischennetz gestalte und verwalte...

    Weiterlesen
  • Eine Bestandsaufnahme

    Es kamen mehrere Faktoren zusammen: die Tatsache, dass ich nicht mehr ganz so kürzlich die 50 überschritten habe hatte ebenso darauf Einfluss wie das heutige trübe Wetter und auch der Fakt, dass ich bereits beinahe alle Wochenendpflichten erledigt habe. Der letzte Stein des Anstoßes war dann aber, dass sich heute zum 125. Mal der Geburtstag von Erich Fromm jährt.

    Weiterlesen

Manche nennen es Blog, manche Web-Seite - ich schreibe hier hin und wieder über meine Erlebnisse, Rückschläge und Erleuchtungen bei meinen Hobbies.

Wer daran teilhaben und eventuell sogar davon profitieren möchte, muss damit leben, daß ich hin und wieder kleine Ausflüge in Bereiche mache, die nichts mit IT, Administration oder Softwareentwicklung zu tun haben.

Ich wünsche allen Lesern viel Spaß und hin und wieder einen kleinen AHA!-Effekt...

PS: Meine öffentlichen Codeberg-Repositories findet man hier.