ConnectorTypeSQLORACLE

class connector_types.connector_type_sqloracle.ConnectorTypeSQLORACLE

Interact with a Oracle database. This connector type supports the execute command. The command expects an SQL query and returns a list of dictionaries containing the result.

Consult the cx_Oracle documentation at https://cx-oracle.readthedocs.io/en/latest/index.html for more information.

Inputs

Name	Type	Default	Description
encoding	str	UTF-8
execute	str
host	str
params	object	None
password	str
port	int	1521
service_name	str
user	str

Outputs

Name	Type	Default	Description
result	object

Constants

input_list = ['encoding', 'execute', 'host', 'params', 'password', 'port', 'service_name', 'user'] output_list = ['result'] ssl_context_inputs = ['check_hostname', 'client_cert', 'client_key', 'server_ca'] version = 1

Methods

execute

details

log

details

one_of_inputs

details

run

details

Example

import flow_api

def handler(system: flow_api.System, this: flow_api.Execution):
    oracle_server_version = this.connect(
        connector_type='SQLORACLE',
        host='my-oracle-server',
        service_name='xe',
        user='username',
        password='password',
        execute='SELECT * FROM v$version',
    ).get('output_value')['result']
    this.log(oracle_server_version=oracle_server_version)