|
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) |
|
|
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) |
|
|
int | Timeout [get, set] |
|
Dictionary< string, string >? | Types [get, set] |
|
string? | CreateTableSql [get] |
|
◆ 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 |
◆ Timeout
int Dacris.Maestro.Data.BaseDataRepository.Timeout |
|
getset |
The documentation for this class was generated from the following file:
- Data/BaseDataRepository.cs