Maestro
Loading...
Searching...
No Matches
Dacris.Maestro.Data.BaseDataRepository Class Referenceabstract
Inheritance diagram for Dacris.Maestro.Data.BaseDataRepository:
Collaboration diagram for Dacris.Maestro.Data.BaseDataRepository:

Public Member Functions

void BulkLoad (DbConnection conn, ICsvLine line, JToken? schemaDef, string tableName)
 
DbConnection OpenSession (List< IDisposable > sessionResources, string connString)
 
virtual void FinishBulkLoad (DbConnection conn, string tableName)
 
virtual void CreateTable (DbConnection conn, JToken? schemaDef, string tableName)
 
virtual void Select (DbConnection conn, string queryConst, string? outputCsvFile, char separator, JToken? parameters, string? schemaPath, string? outputPath)
 
virtual void Modify (DbConnection conn, string queryConst, JToken? parameters)
 
- Public Member Functions inherited from Dacris.Maestro.Data.IDataRepository

Protected Member Functions

DbParameter ConstructParameter (string? name, object? value)
 
virtual void CheckConnection (DbConnection conn)
 
string string DataType[] ParseSchema (JToken? schemaDef)
 
string string Value[] ParseValues (JToken? valueDef)
 
virtual void OutputSchemaToState (ReadOnlyCollection< DbColumn > schema, string? schemaPath)
 
virtual IEnumerable< string[]> GetRows (DbDataReader reader)
 
virtual void AddParameters (JToken? parameters, DbCommand command)
 
virtual string TranslateType (string inputType)
 
virtual ? object GetValueByType (string type, string value)
 
virtual Type GetColumnType (string jsonType)
 

Protected Attributes

string Name
 

Properties

int Timeout [get, set]
 
Dictionary< string, string >? Types [get, set]
 
string? CreateTableSql [get]
 
- Properties inherited from Dacris.Maestro.Data.IDataRepository

Member Function Documentation

◆ BulkLoad()

void Dacris.Maestro.Data.BaseDataRepository.BulkLoad ( DbConnection conn,
ICsvLine line,
JToken? schemaDef,
string tableName )
abstract

◆ CreateTable()

virtual void Dacris.Maestro.Data.BaseDataRepository.CreateTable ( DbConnection conn,
JToken? schemaDef,
string tableName )
inlinevirtual

◆ FinishBulkLoad()

virtual void Dacris.Maestro.Data.BaseDataRepository.FinishBulkLoad ( DbConnection conn,
string tableName )
inlinevirtual

◆ Modify()

virtual void Dacris.Maestro.Data.BaseDataRepository.Modify ( DbConnection conn,
string queryConst,
JToken? parameters )
inlinevirtual

◆ OpenSession()

DbConnection Dacris.Maestro.Data.BaseDataRepository.OpenSession ( List< IDisposable > sessionResources,
string connString )
abstract

◆ Select()

virtual void Dacris.Maestro.Data.BaseDataRepository.Select ( DbConnection conn,
string queryConst,
string? outputCsvFile,
char separator,
JToken? parameters,
string? schemaPath,
string? outputPath )
inlinevirtual

Property Documentation

◆ Timeout

int Dacris.Maestro.Data.BaseDataRepository.Timeout
getset

The documentation for this class was generated from the following file: