Function newConnector

src/lib/connectors/index.ts:13–26

(connection: Connection)

}

export const newConnector = (connection: Connection): Connector => {
  switch (connection.engineType) {
    case Engine.MySQL:
      return mysql(connection);
    case Engine.PostgreSQL:
      return postgres(connection);
    case Engine.MSSQL:
      return mssql(connection);
    case Engine.OceanBase:
      return mysql(connection);
    default:
      throw new Error("Unsupported engine type.");
  }
};