Package com.github.hakenadu.javalangchains.chains.data.retrieval

Class JdbcRetrievalChain

java.lang.Object

com.github.hakenadu.javalangchains.chains.data.retrieval.RetrievalChain

com.github.hakenadu.javalangchains.chains.data.retrieval.JdbcRetrievalChain

All Implemented Interfaces:

Chain<String,Stream<Map<String,String>>>

public class JdbcRetrievalChain
extends RetrievalChain

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	JdbcRetrievalChain.DocumentCreator	Wrapper interface for Lambdas that act as document creators for a JDBC ResultSet.

Constructor Summary

Constructors

Constructor	Description
JdbcRetrievalChain(Supplier<Connection> connectionSupplier, int maxDocumentCount)	Creates an instance of JdbcRetrievalChain using createQuery(String, String, String) for SQL statement creation and `content`, `source` as the result columns and `Documents` as the table.
JdbcRetrievalChain(Supplier<Connection> connectionSupplier, String table, String contentColumn, int maxDocumentCount)	Creates an instance of JdbcRetrievalChain using createQuery(String, String, String) for SQL statement creation.
JdbcRetrievalChain(Supplier<Connection> connectionSupplier, Function<String,org.apache.commons.lang3.tuple.Pair<String,List<Object>>> queryBuilder, JdbcRetrievalChain.DocumentCreator documentCreator, int maxDocumentCount)	Creates an instance of JdbcRetrievalChain

Method Summary

Modifier and Type	Method	Description
Stream<Map<String,String>>	run(String input)	Execute this Chain

Methods inherited from class com.github.hakenadu.javalangchains.chains.data.retrieval.RetrievalChain

getMaxDocumentCount

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.github.hakenadu.javalangchains.chains.Chain

chain

Constructor Details

JdbcRetrievalChain

public JdbcRetrievalChain(Supplier<Connection> connectionSupplier, Function<String,org.apache.commons.lang3.tuple.Pair<String,List<Object>>> queryBuilder, JdbcRetrievalChain.DocumentCreator documentCreator, int maxDocumentCount)

Creates an instance of JdbcRetrievalChain

Parameters:

connectionSupplier - connectionSupplier

documentCreator - documentCreator

queryBuilder - queryBuilder

maxDocumentCount - RetrievalChain.getMaxDocumentCount()

JdbcRetrievalChain

public JdbcRetrievalChain(Supplier<Connection> connectionSupplier, String table, String contentColumn, int maxDocumentCount)

Creates an instance of JdbcRetrievalChain using createQuery(String, String, String) for SQL statement creation.

Parameters:

connectionSupplier - connectionSupplier

table - Name of the document table used for query creation

maxDocumentCount - RetrievalChain.getMaxDocumentCount()

JdbcRetrievalChain

public JdbcRetrievalChain(Supplier<Connection> connectionSupplier, int maxDocumentCount)

Creates an instance of JdbcRetrievalChain using createQuery(String, String, String) for SQL statement creation and `content`, `source` as the result columns and `Documents` as the table.

Parameters:

connectionSupplier - connectionSupplier

maxDocumentCount - RetrievalChain.getMaxDocumentCount()

Method Details

run

public Stream<Map<String,String>> run(String input)

Description copied from interface: Chain

Execute this Chain

Parameters:

input - this chain's input

Returns:

this chain's output