Skip to main content

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

NameTypeDefaultDescription
encodingstrUTF-8
executestr
hoststr
paramsobjectNone
passwordstr
portint1521
service_namestr
userstr

Outputs

NameTypeDefaultDescription
execution_idintThe ID of the connection execution
messagestrThe ended message for the connection. If the connection ended with an error, the message will contain information about what went wrong
resultobject
statusstrThe ended status for the connection. Either "success" or "error".

Constants

input_list = ['encoding', 'execute', 'host', 'params', 'password', 'port', 'service_name', 'user']output_list = ['result']version = 1

Methods

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)