This sample demonstrates the use of the Database Change Data Capture Input Adapter for Oracle and SQL Server databases.
Scripts are provided for Windows to configure your database for change data capture. If using SQL Server, modify
setup-cdc-sql-server.sqlwith your site-specific database credentials. Run
setup-cdc-sql-server.sqlto configure CDC for your Oracle or SQL Server database, respectively. In addition to configuring change data capture, these scripts above create a database table,
Customers, for which change activity is captured.
Add the JAR file containing the JDBC driver for your database —
sqljdbc4.jar— to your Maven repository and or add the dependency to the project's pom file.
In StreamBase Studio, import this sample with the following steps:
From the top-level menu, click→ .
chanarrow the list of options.
Select change-data-capture sample from the Native Database Connectivity Adapters category.
StreamBase Studio creates a project for the sample.
In the Project Explorer, open the sample you just loaded.
Open the package folder (most samples contain a single package folder. Open the top-level package folder if your sample contains more than one folder).
change-data-capture-sql-server.sbappfile to open the sample application for Oracle or SQL Server, respectively.
Select the adapter icon to open the Properties view for the adapter.
Select the Adapter Settings tab and note that the populated values match those configured through the scripts above.
Click the Run button. This opens the SB Test/Debug perspective and the application.
If you see red marks, wait a moment for the project in Studio to load its features.
If red marks do not resolve themselves in a moment, select the project and right-click→ from the context menu.
In the Studio's Output Streams view, observe tuples emitted on the adapter's
Statusoutput port indicating it has connected to the database and enabled CDC.
Using a tool such as sqldeveloper or SQLPlus for Oracle or SQL Server Management Studio or sqlcmd for SQL Server, modify the contents of the Customers table by inserting, updating, and deleting records. If using Oracle, commit the changes to ensure the redo log gets written promptly.
In Studio's Output Streams view, observe tuples emitted on the Capture output port indicating changes have been made to the
When done, press F9 or click the Stop Running Application button.
When you load the sample into StreamBase Studio, Studio copies the sample project's files to your Studio workspace, which is normally part of your home directory, with full access rights.
Load this sample in StreamBase Studio, and thereafter use the Studio workspace copy of the sample to run and test it, even when running from the command prompt.
Using the workspace copy of the sample avoids permission problems. The default workspace location for this sample is:
See Default Installation Directories for the default location of
studio-workspace on your system.