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

  • When Someone Requests a Jimi Hendrix Song

    23.08.2020

    Er hier ist mir schon einige Male mit interessanten Videos aufgefallen...

    Weiterlesen

Neueste Artikel

  • Anlehnung an todo.txt für collectedlinks

    Ich habe den Generator für meine Heimatseite im Zwischennetz wieder um ein neues Feture erweitert.

    Weiterlesen
  • NeoVim und ausrangierte Plugins

    Ich habe nun seit geraumer Zeit NeoVim im Einsatz im Produktivbetrieb zum Entwickeln - nicht nur - von Software. Dabei hat sich gezeigt, dass ich meinem Ziel, der Philosophie des Einsatzes möglichst weniger Plugins immer näher komme:

    Weiterlesen
  • Kritzelgenerator

    Ich habe mal wieder etwas im Internet gefunden, das mich herausforderte, eine Fingerübung in Java abzuhalten:

    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.