| | |
- siirto.base.Base(builtins.object)
-
- BaseDataBaseOperator
class BaseDataBaseOperator(siirto.base.Base) |
| |
Abstract base class for all database operators.
To derive this class, you are expected to override the constructor as well
as the 'execute' method.
Operators derived from this class should perform following steps:
1. implement the execute method
a. implement the full load
b. implement the CDC
c. handle the fail-overs
d. persist the state
:param connection_string: connection string for the database
:type connection_string: str
:param load_type: type of load to run for the job. LoadType.Full_Load,
LoadType.CDC or LoadType.Full_Load_And_CDC
:type connection_string: LoadType
:param table_names: tables which needs to be considered
:type table_names: List[str]
:param full_load_plugin_name: name of full load plugin to be used in execute
:type full_load_plugin_name: str
:param cdc_plugin_name: name of cdc plugin to be used in execute
:type cdc_plugin_name: str
:param output_location: output location for the full load and cdc
:type output_location: str
|
| |
- Method resolution order:
- BaseDataBaseOperator
- siirto.base.Base
- builtins.object
Methods defined here:
- __init__(self, connection_string:str, load_type:siirto.shared.enums.LoadType=<LoadType.Full_Load_And_CDC: 3>, table_names:List[str]=[], full_load_plugin_name:str=None, cdc_plugin_name:str=None, output_location:str=None, *args, **kwargs)
- Initialize self. See help(type(self)) for accurate signature.
- execute(self)
- This is the main method to derive when implementing an operator.
Class methods defined here:
- get_object(database_operator_type:str, database_operator_name:str) from builtins.type
- Factory.
Get the databae operator type object having name `database_operator_name`
:param database_operator_type: type of operator to load
:param database_operator_name: name of operator to load
:return: operator
- load_derived_classes() from builtins.type
- load the derived operator classes available in the current directory and
ending with _operator.py
Data and other attributes defined here:
- operator_name = None
- operator_type = None
Data descriptors inherited from siirto.base.Base:
- __dict__
- dictionary for instance variables (if defined)
- __weakref__
- list of weak references to the object (if defined)
| |