pub(open) trait Engine {
  render(Self, stmt : Statement) -> (String, FixedArray[Param])
  tx_begin_sql(Self) -> String
  tx_commit_sql(Self) -> String
  tx_rollback_sql(Self) -> String
  tx_savepoint_sql(Self, name : String) -> String
  tx_rollback_to_savepoint_sql(Self, name : String) -> String
  async migrate_table(Self, table_schema : Json) -> QueryResult
  async exec_raw(Self, sql : String, params : FixedArray[Param]) -> QueryResult
  preload_in_sql(Self, table : String, key_col : String, count : Int) -> String
  preload_many_to_many_sql(Self, target_table : String, target_key : String, join_table : String, join_owner_key : String, join_target_key : String, count : Int) -> String
  close(Self) -> Unit
}

pub(open) trait QueryBuilder {
  to_statement(Self) -> Statement
}

pub(open) trait ToParam {
  to_param(Self) -> Param
}

pub(all) struct DeleteStatement {
  from : String
  where_ : FixedArray[Where]
}

pub(all) struct InsertStatement {
  into : String
  columns : FixedArray[String]
  values : FixedArray[Param]
}

pub(all) enum OrderBy {
  Asc(String)
  Desc(String)
}

pub(all) enum Param {
  Null
  Bool(Bool)
  Byte(Byte)
  Int(Int)
  Int16(Int16)
  UInt16(UInt16)
  UInt(UInt)
  UInt64(UInt64)
  Int64(Int64)
  BigInt(
@moonbitlang/core/bigint.BigInt
BigInt)
  Float(Float)
  Double(Double)
  Decimal(String)
  Date(
@oboard/morm/time.PlainDate
PlainDate)
  Time(
@oboard/morm/time.PlainTime
PlainTime)
  DateTime(
@oboard/morm/time.PlainDateTime
PlainDateTime)
  Timestamp(
@oboard/morm/time.ZonedDateTime
ZonedDateTime)
  Uuid(String)
  Json(Json)
  String(String)
  Bytes(Bytes)
}

pub(all) struct QueryResult {
  ok : Bool
  rows_affected : Int
  rows : FixedArray[Json]
  error : String?
}

pub(all) struct SelectStatement {
  select : String
  from : String
  joins : FixedArray[String]
  where_ : FixedArray[Where]
  order_by : FixedArray[OrderBy]
  limit : Int?
  offset : Int?
}

pub(all) struct Set {
  col : String
  value : Param
}

pub(all) enum Statement {
  Select(SelectStatement)
  Insert(InsertStatement)
  Upsert(UpsertStatement)
  Update(UpdateStatement)
  Delete(DeleteStatement)
}

pub(all) struct UpdateStatement {
  table : String
  sets : FixedArray[Set]
  where_ : FixedArray[Where]
}

pub(all) struct UpsertStatement {
  table : String
  sets : FixedArray[Set]
  conflict_target : FixedArray[String]
  update_sets : FixedArray[Set]
}

pub(all) struct Where {
  col : String
  value : Param
  ty : WhereType
}

pub(all) enum WhereType {
  Eq
  Ne
  Gt
  Lt
  Gte
  Lte
  Like
}

async fn[E : Engine, Q : QueryBuilder] exec_query(engine : E, query : Q) -> QueryResult

fn preload_in_sql_dollar(table : String, key_col : String, count : Int) -> String

fn preload_in_sql_qmark(table : String, key_col : String, count : Int) -> String

fn preload_many_to_many_sql_dollar(target_table : String, target_key : String, join_table : String, join_owner_key : String, join_target_key : String, count : Int) -> String

fn preload_many_to_many_sql_qmark(target_table : String, target_key : String, join_table : String, join_owner_key : String, join_target_key : String, count : Int) -> String

fn render_default_sql(stmt : Statement) -> (String, FixedArray[Param])

fn[T : ToParam] to_param(value : T) -> Param

async fn[E : Engine] tx_begin(engine : E) -> QueryResult

async fn[E : Engine] tx_commit(engine : E) -> QueryResult

async fn[E : Engine] tx_rollback(engine : E) -> QueryResult

async fn[E : Engine] tx_rollback_to_savepoint(engine : E, name : String) -> QueryResult

async fn[E : Engine] tx_savepoint(engine : E, name : String) -> QueryResult