Maestro
Loading...
Searching...
No Matches
Dacris.Maestro.Data.Postgres Class Reference
Inheritance diagram for Dacris.Maestro.Data.Postgres:
Collaboration diagram for Dacris.Maestro.Data.Postgres:

Public Member Functions

override void CreateTable (DbConnection conn, JToken? schemaDef, string tableName)
 
override DbConnection OpenSession (List< IDisposable > resources, string connString)
 
override void BulkLoad (DbConnection conn, ICsvLine line, JToken? schemaDef, string tableName)
 
- Public Member Functions inherited from Dacris.Maestro.Data.BaseDataRepository
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 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

override DbParameter ConstructParameter (string? name, object? value)
 
- Protected Member Functions inherited from Dacris.Maestro.Data.BaseDataRepository
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)
 

Additional Inherited Members

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

Member Function Documentation

◆ BulkLoad()

override void Dacris.Maestro.Data.Postgres.BulkLoad ( DbConnection conn,
ICsvLine line,
JToken? schemaDef,
string tableName )
inline

◆ CreateTable()

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

◆ OpenSession()

override DbConnection Dacris.Maestro.Data.Postgres.OpenSession ( List< IDisposable > resources,
string connString )
inline

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