/*-
 * Copyright 2005-2007 Guram Dukashvili
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 *
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 * SUCH DAMAGE.
 */
//---------------------------------------------------------------------------
#include <adicpp/adicpp.h>
//---------------------------------------------------------------------------
namespace adicpp {
//---------------------------------------------------------------------------
Database * Database::newDatabase(const ksys::ConfigSection * config)
{
  ksys::ConfigSection defConfig;
  if( config == NULL ) config = &defConfig;
  utf8::String stype0(config->valueByPath("server_type","MYSQL"));
  utf8::String stype(stype0.lower());
  utf8::String section(stype);
  if( stype.strcmp("firebird") == 0 ){
    fbcpp::api.clientLibrary(config->valueByPath(section + ".client_library"));
    ksys::AutoPtr<FirebirdDatabase> p(newObject<FirebirdDatabase>());
    p->name(config->valueByPath(section + ".database"));
    p->params().add("user_name",config->valueByPath(section + ".user","sysdba"));
    p->params().add("password",config->valueByPath(section + ".password","masterkey"));
    p->params().add("role",config->valueByPath(section + ".role"));
    p->params().add("sql_dialect",config->valueByPath(section + ".dialect",3));
    p->params().add("page_size",config->valueByPath(section + ".page_size",16384));
    p->params().add("lc_ctype",config->valueByPath(section + ".default_charset","UNICODE_FSS"));
    p->params().add("lc_messages",config->valueByPath(section + ".messages_charset","WIN1251"));
    return p.ptr(NULL);
  }
  else if( stype.strcmp("mysql") == 0 ){
    mycpp::api.clientLibrary(config->valueByPath(section + ".client_library"));
    ksys::AutoPtr<MYSQLDatabase> p(newObject<MYSQLDatabase>());
    p->name(config->valueByPath(section + ".database"));
    p->params().add("user_name",config->valueByPath(section + ".user","root"));
    p->params().add("password",config->valueByPath(section + ".password"));
    p->params().add("protocol",config->valueByPath(section + ".protocol"));
    p->params().add("connect_timeout",config->valueByPath(section + ".connect_timeout",0));
    p->params().add("read_timeout",config->valueByPath(section + ".read_timeout",0));
    p->params().add("write_timeout",config->valueByPath(section + ".write_timeout",0));
    p->params().add("reconnect",config->valueByPath(section + ".reconnect",false));
    p->params().add("compress",config->valueByPath(section + ".compress",false));
    return p.ptr(NULL);
  }
  else if( stype.strcmp("odbc") == 0 ){
    odbcpp::api.clientLibrary(config->valueByPath(section + ".client_library"));
    ksys::AutoPtr<ODBCDatabase> p(newObject<ODBCDatabase>());
    p->connection(config->valueByPath(section + ".connection"));
    return p.ptr(NULL);
  }
  newObjectV1C2<ksys::Exception>(EINVAL,"unknown or unsupported server type: " + stype0)->throwSP();
  return NULL;
}
//---------------------------------------------------------------------------
} // namespace adicpp
//---------------------------------------------------------------------------