DataAccessConnectorBase

AtlasX.Engine.DataAccess.Core.Base
Abstract base class สำหรับ database connector ทุกตัวใน DataAccess library

Namespace: AtlasX.Engine.DataAccess.Core.Base
Implements: IDataAccessConnector
Inherited by: OracleConnector, PostgreSqlConnector, SqlServerConnector, MongoDbConnector, RedisConnector

Properties

Name	Description
IsConnected	ตรวจสอบว่า connection เปิดอยู่หรือไม่ (true = Open)

Methods

Name	Return	Description
`OpenAsync(CancellationToken)`	`void`	เปิด connection ไปยัง database
`CloseAsync(CancellationToken)`	`void`	ปิด connection และ dispose resources
`ExecuteStatementAsync(String, Dictionary, DbExecutionOptions, CancellationToken)`	`int`	Execute SQL statement และคืนจำนวน rows ที่ได้รับผลกระทบ
`ExecuteScalarStatementAsync<TResult>(String, Dictionary, DbExecutionOptions, CancellationToken)`	`TResult?`	Execute SQL statement และคืนค่า scalar value
`QueryStatementAsync<TResult>(String, Dictionary, DbExecutionOptions, CancellationToken)`	`TResult`	Execute SQL SELECT และ map ผลลัพธ์เป็น TResult
`ExecuteProcedureAsync(String, Dictionary, DbExecutionOptions, CancellationToken)`	`QueryResult`	Execute Stored Procedure และคืน QueryResult
`DisposeAsync()`	`void`	ปิด connection และคืน resources ทั้งหมด

Methods Details

OpenAsync(CancellationToken)

เปิด connection ไปยัง database ถ้ายังไม่ได้เปิด
แต่หาก IsConnected เป็น true อยู่แล้วจะ skip โดยไม่เปิดซ้ำ

Parameter	Type	Required	Description
`cancellationToken`	`CancellationToken`	Optional	Token สำหรับยกเลิก operation

CloseAsync(CancellationToken)

ปิด connection และ dispose resources
แต่หากconnection เป็น null หรือปิดอยู่แล้วจะ skip โดยไม่ทำอะไร

Parameter	Type	Required	Description
`cancellationToken`	`CancellationToken`	Optional	Token สำหรับยกเลิก operation

ExecuteStatementAsync(String, Dictionary, DbExecutionOptions, CancellationToken)

Execute SQL statement (INSERT / UPDATE / DELETE) และคืนจำนวนรายการ (rows) ที่ได้รับผลกระทบ

Parameter	Type	Required	Description
`sql`	`string`	Required	SQL statement
`parameters`	`Dictionary<string, object>?`	Optional	Parameters สำหรับ SQL
`options`	`DbExecutionOptions?`	Optional	Execution options เช่น timeout
`cancellationToken`	`CancellationToken`	Optional	Token สำหรับยกเลิก operation

QueryStatementAsync<TResult>(String, Dictionary<String, Object>, DbExecutionOptions, CancellationToken)

Execute SQL SELECT statement และ map ผลลัพธ์เป็น TResult

Parameter	Type	Required	Description
`sql`	`string`	Required	SQL SELECT statement
`parameters`	`Dictionary<string, object>?`	Optional	Parameters สำหรับ SQL
`options`	`DbExecutionOptions?`	Optional	Execution options เช่น timeout
`cancellationToken`	`CancellationToken`	Optional	Token สำหรับยกเลิก operation

ExecuteProcedureAsync(String, Dictionary<String, Object>, DbExecutionOptions, CancellationToken)

Execute Stored Procedure และ map output parameters กลับเป็น QueryResult

Parameter	Type	Required	Description
`procedureName`	`string`	Required	ชื่อ Stored Procedure
`parameters`	`Dictionary<string, object>?`	Optional	Input parameters (ใช้ชื่อโดยไม่ต้องมี prefix PI_)
`options`	`DbExecutionOptions?`	Optional	Execution options เช่น timeout, trace
`cancellationToken`	`CancellationToken`	Optional	Token สำหรับยกเลิก operation

DisposeAsync()

ปิด connection และคืน resources ทั้งหมด