...
If you want to read from a database, you may use the DATABASESOURCE operator. For an existing connection called "con1" we can read from the table called "main":
| Code Block |
|---|
datastream = DATABASESOURCE({connection='con1', table='main'}) |
Since PQL allows to create views and names for reusing connections (see The Odysseus Procedural Query Language (PQL) - Usage and Development), you may use this syntax, for example to create a dedicated source entry.
| Code Block |
|---|
datastream := DATABASESOURCE({connection='con1', table='main'}) |
To reuseThen you can use this
Using a connection in StreamSQL (CQL)
...