/*
 * Copyright (c) 2014-2016, Santili Y-HRAH KRONG
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without modification,
 * are permitted provided that the following conditions are met:
 *
 *   Redistributions of source code must retain the above copyright notice, this
 *   list of conditions and the following disclaimer.
 *
 *   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 COPYRIGHT HOLDERS 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 COPYRIGHT HOLDER 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 <sqlcreatetable.hpp>

namespace cppsqlx
{

SQLCreateTable::SQLCreateTable(std::string tablename)
{ 
    _objectname = tablename; 
    _objecttype = "TABLE";
}


std::string SQLCreateTable::toString()
{
    std::string query;
    query = "CREATE ";
    query += _objecttype + " " + _objectname;
    if(_ds)
    {
      query += "(\n";
      for(auto i = 1; i <= _ds->rowSize() ; i++)
      {
         query += _ds->at(i).name() + "   " + _ds->at(i).type();
         if(i != _ds->rowSize())
           query += ",\n";
      }
      query += "\n)";
    }
    else
    {
       query += " AS\n";
       query += _select;
    }

    switch(sqldialect_)
    {
       case DBPROVIDER::GREENPLUM :
       {
          query+= "\nDISTRIBUTED RANDOMLY"; 
          break;
       }
       default:
          break;
    }

    return query;
};


SQLCreateTable& SQLCreateTable::as(std::string  select)
{
    _select = select;
    return *this;
}


SQLCreateTable& SQLCreateTable::sameAs(std::shared_ptr<Dataset> ds)
{
    _ds = ds;
    return *this;
}


};/*namespace cppsqlx*/
