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.
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.
Synchronisieren Zwischenablage mit XPRA
01.09.2019
Nachdem ich neulich mein XPRA-Skript nochmal ein wenig erneuert habe, hatte ich ein Problem:
Weiterlesen...Android Basteln C und C++ Chaos Datenbanken Docker dWb+ ESP Wifi Garten Geo Git(lab|hub) Go GUI Gui Hardware Java Jupyter Komponenten Links Linux Markdown Markup Music Numerik PKI-X.509-CA Python QBrowser Rants Raspi Revisited Security Software-Test sQLshell TeleGrafana Verschiedenes Video Virtualisierung Windows Upcoming...
Eine neue Musikreihe/Show auf Youtube gefunden...
Weiterlesen...Ich habe neulich über meinen kleinen Erfolg berichtet, einen Futro über das Netzwerk zu booten. Das war allerdings nur das Minimalziel...
Weiterlesen...Ich habe hier bereits von den Anfängen meiner Versuche berichtet, Ersatz für die Raspis und vergleichbarer Hardware zu finden.
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, muß 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 GitHub-Repositories findet man hier - meine öffentlichen GitLab-Repositories finden sich dagegen hier.