Interface DbDriver

interface DbDriver {
    beginTransaction(): Promise<void>;
    commitTransaction(): Promise<void>;
    connect(): Promise<void>;
    disconnect(): Promise<void>;
    prepare(sql: string): Promise<DatabaseResult<PreparedDriverStatement>>;
    query<T = any>(
        sql: string,
        params?: QueryParams,
    ): Promise<DatabaseResult<QueryResponse<T>>>;
    rollbackTransaction(): Promise<void>;
    stream<T = any>(
        sql: string,
        params: QueryParams,
        onRow: (row: T) => void,
    ): Promise<DatabaseResult<void>>;
}