The JDBC Lookup query pipeline stage is used to call out to a database as part of a pipeline stage, to inject results into either the context/request or the pipeline document.
For example, if you needed to look up a user from a DB and add their profile information onto a request for downstream use in a pipeline, the JDBC Lookup Stage would facilitate this.
You must first Upload a JDBC Driver to Managed Fusion.
Upload a JDBC Driver to Managed Fusion
The JDBC connector fetches documents from a relational database via SQL queries. Under the hood, this connector implements the Solr DataImportHandler (DIH) plugin.Managed Fusion stores JDBC drivers in the blob store. You can upload a driver using the Managed Fusion UI or the Blob Store API. Learn more about the JDBC V2 connector.
Upload the JAR file to Managed Fusion’s blob store using the /blobs/{id} endpoint.Specify an arbitrary blob ID, and a resourceType value of plugin:connector, as in this example:
Managed Fusion automatically publishes the event to the cluster, and the listeners perform the driver installation process on each node.
If the blob ID is identical to an existing one, the old driver will be uninstalled and the new driver will installed in its place. To get the list of existing blob IDs, run: curl -u USERNAME:PASSWORD https://FUSION_HOST:FUSION_PORT/api/blobs
An example of setup for a JDBC Lookup query pipeline stage.Upload stage config via POST to Managed Fusion REST API endpoint api/query-stages/instances
Copy
curl -u USERNAME:PASSWORD -X POST -H "Content-Type: application/json" -d '{"id": "jdbc-quer","type":"jdbc-query-lookup","driver":"postgresql-9.3-1101-jdbc4.jar","connection":"jdbc:postgresql:database","username":"user","password":"password1","preparedStatement":"select ID as id from DATABASE;"}' http://EXAMPLE_COMPANY.lucidworks.cloud/api/query-stages/instances
Replace EXAMPLE_COMPANY with the name provided by your Lucidworks representative.
When entering configuration values in the UI, use unescaped characters, such as \t for the tab character. When entering configuration values in the API, use escaped characters, such as \\t for the tab character.
