295 lines
8.7 KiB
C++
295 lines
8.7 KiB
C++
/*****************************************************************************
|
|
*
|
|
* This file is part of Mapnik (c++ mapping toolkit)
|
|
*
|
|
* Copyright (C) 2007 Artem Pavlenko
|
|
*
|
|
* This library is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU Lesser General Public
|
|
* License as published by the Free Software Foundation; either
|
|
* version 2.1 of the License, or (at your option) any later version.
|
|
*
|
|
* This library is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
* Lesser General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Lesser General Public
|
|
* License along with this library; if not, write to the Free Software
|
|
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
|
|
*
|
|
*****************************************************************************/
|
|
// $Id$
|
|
|
|
#include "occi_datasource.hpp"
|
|
#include "occi_featureset.hpp"
|
|
|
|
// mapnik
|
|
#include <mapnik/ptree_helpers.hpp>
|
|
|
|
// boost
|
|
#include <boost/lexical_cast.hpp>
|
|
#include <boost/tokenizer.hpp>
|
|
|
|
// stl
|
|
#include <string>
|
|
#include <algorithm>
|
|
#include <set>
|
|
#include <sstream>
|
|
#include <iomanip>
|
|
|
|
using std::clog;
|
|
using std::endl;
|
|
using std::vector;
|
|
|
|
using mapnik::datasource;
|
|
using mapnik::parameters;
|
|
using mapnik::query;
|
|
using mapnik::featureset_ptr;
|
|
using mapnik::layer_descriptor;
|
|
using mapnik::attribute_descriptor;
|
|
using mapnik::datasource_exception;
|
|
using mapnik::Envelope;
|
|
using mapnik::coord2d;
|
|
|
|
using oracle::occi::Environment;
|
|
using oracle::occi::Connection;
|
|
using oracle::occi::Statement;
|
|
using oracle::occi::ResultSet;
|
|
using oracle::occi::MetaData;
|
|
using oracle::occi::SQLException;
|
|
using oracle::occi::Type;
|
|
using oracle::occi::StatelessConnectionPool;
|
|
|
|
|
|
DATASOURCE_PLUGIN(occi_datasource)
|
|
|
|
occi_datasource::occi_datasource(parameters const& params)
|
|
: datasource (params),
|
|
table_(*params.get<std::string>("table","")),
|
|
geometry_field_(*params.get<std::string>("geometry_field","")),
|
|
type_(datasource::Vector),
|
|
extent_initialized_(false),
|
|
desc_(*params.get<std::string>("type"),"utf-8")
|
|
{
|
|
boost::optional<int> initial_size = params_.get<int>("inital_size",1);
|
|
boost::optional<int> max_size = params_.get<int>("max_size",10);
|
|
|
|
multiple_geometries_ = *params_.get<mapnik::boolean>("multiple_geometries",false);
|
|
|
|
boost::optional<std::string> ext = params_.get<std::string>("extent");
|
|
if (ext)
|
|
{
|
|
boost::char_separator<char> sep(",");
|
|
boost::tokenizer<boost::char_separator<char> > tok(*ext,sep);
|
|
unsigned i = 0;
|
|
bool success = false;
|
|
double d[4];
|
|
for (boost::tokenizer<boost::char_separator<char> >::iterator beg=tok.begin();
|
|
beg!=tok.end();++beg)
|
|
{
|
|
try
|
|
{
|
|
d[i] = boost::lexical_cast<double>(*beg);
|
|
}
|
|
catch (boost::bad_lexical_cast & ex)
|
|
{
|
|
std::clog << ex.what() << "\n";
|
|
break;
|
|
}
|
|
if (i==3)
|
|
{
|
|
success = true;
|
|
break;
|
|
}
|
|
++i;
|
|
}
|
|
if (success)
|
|
{
|
|
extent_.init(d[0],d[1],d[2],d[3]);
|
|
extent_initialized_ = true;
|
|
}
|
|
}
|
|
|
|
// connect to environment
|
|
try
|
|
{
|
|
env_ = Environment::createEnvironment ((Environment::Mode) Environment::OBJECT); // Environment::THREADED_MUTEXED
|
|
RegisterClasses (env_);
|
|
|
|
pool_ = env_->createStatelessConnectionPool(
|
|
*params.get<std::string>("user"),
|
|
*params.get<std::string>("password"),
|
|
*params.get<std::string>("host"),
|
|
*max_size,
|
|
*initial_size,
|
|
1,
|
|
StatelessConnectionPool::HOMOGENEOUS);
|
|
}
|
|
catch (SQLException &ex)
|
|
{
|
|
throw datasource_exception(ex.getMessage());
|
|
}
|
|
|
|
// get SRID from geometry metadata
|
|
{
|
|
occi_connection_ptr conn (pool_);
|
|
|
|
std::ostringstream s;
|
|
s << "select srid from " << SDO_GEOMETRY_METADATA_TABLE << " where";
|
|
s << " lower(table_name) = lower('" << table_ << "') and";
|
|
s << " lower(column_name) = lower('" << geometry_field_ << "')";
|
|
|
|
try
|
|
{
|
|
ResultSet* rs = conn.execute_query (s.str());
|
|
if (rs && rs->next ())
|
|
{
|
|
srid_ = rs->getInt(1);
|
|
}
|
|
}
|
|
catch (SQLException &ex)
|
|
{
|
|
throw datasource_exception(ex.getMessage());
|
|
}
|
|
}
|
|
|
|
// get table metadata
|
|
occi_connection_ptr conn (pool_);
|
|
MetaData metadata = (*conn)->getMetaData(table_.c_str(), MetaData::PTYPE_TABLE);
|
|
vector<MetaData> listOfColumns = metadata.getVector(MetaData::ATTR_LIST_COLUMNS);
|
|
|
|
for (unsigned int i=0;i<listOfColumns.size();++i)
|
|
{
|
|
MetaData columnObj = listOfColumns[i];
|
|
|
|
std::string fld_name = columnObj.getString(MetaData::ATTR_NAME);
|
|
int type_oid = columnObj.getInt(MetaData::ATTR_DATA_TYPE);
|
|
|
|
#if 0
|
|
int type_code = columnObj.getInt(MetaData::ATTR_TYPECODE);
|
|
if (type_code == OCCI_TYPECODE_OBJECT)
|
|
{
|
|
desc_.add_descriptor(attribute_descriptor(fld_name,mapnik::Object));
|
|
continue;
|
|
}
|
|
#endif
|
|
|
|
switch (type_oid)
|
|
{
|
|
case oracle::occi::OCCIINT:
|
|
case oracle::occi::OCCIUNSIGNED_INT:
|
|
desc_.add_descriptor(attribute_descriptor(fld_name,mapnik::Integer));
|
|
break;
|
|
case oracle::occi::OCCIFLOAT:
|
|
case oracle::occi::OCCIBFLOAT:
|
|
case oracle::occi::OCCIDOUBLE:
|
|
case oracle::occi::OCCIBDOUBLE:
|
|
case oracle::occi::OCCINUMBER:
|
|
case oracle::occi::OCCI_SQLT_NUM:
|
|
desc_.add_descriptor(attribute_descriptor(fld_name,mapnik::Double));
|
|
break;
|
|
case oracle::occi::OCCICHAR:
|
|
case oracle::occi::OCCISTRING:
|
|
case oracle::occi::OCCI_SQLT_AFC:
|
|
case oracle::occi::OCCI_SQLT_AVC:
|
|
case oracle::occi::OCCI_SQLT_CHR:
|
|
case oracle::occi::OCCI_SQLT_LVC:
|
|
case oracle::occi::OCCI_SQLT_STR:
|
|
case oracle::occi::OCCI_SQLT_VCS:
|
|
case oracle::occi::OCCI_SQLT_VNU:
|
|
case oracle::occi::OCCI_SQLT_VBI:
|
|
case oracle::occi::OCCI_SQLT_VST:
|
|
case oracle::occi::OCCI_SQLT_RDD:
|
|
desc_.add_descriptor(attribute_descriptor(fld_name,mapnik::String));
|
|
break;
|
|
case oracle::occi::OCCIDATE:
|
|
case oracle::occi::OCCITIMESTAMP:
|
|
case oracle::occi::OCCI_SQLT_DAT:
|
|
case oracle::occi::OCCI_SQLT_TIMESTAMP:
|
|
case oracle::occi::OCCI_SQLT_TIMESTAMP_LTZ:
|
|
case oracle::occi::OCCI_SQLT_TIMESTAMP_TZ:
|
|
case oracle::occi::OCCIPOBJECT:
|
|
#ifdef MAPNIK_DEBUG
|
|
clog << "unsupported type_oid="<<type_oid<<endl;
|
|
#endif
|
|
break;
|
|
default: // shouldn't get here
|
|
#ifdef MAPNIK_DEBUG
|
|
clog << "unknown type_oid="<<type_oid<<endl;
|
|
#endif
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
occi_datasource::~occi_datasource()
|
|
{
|
|
if (env_)
|
|
{
|
|
env_->terminateStatelessConnectionPool (pool_);
|
|
Environment::terminateEnvironment (env_);
|
|
}
|
|
}
|
|
|
|
std::string const occi_datasource::name_="occi";
|
|
|
|
std::string occi_datasource::name()
|
|
{
|
|
return name_;
|
|
}
|
|
|
|
int occi_datasource::type() const
|
|
{
|
|
return type_;
|
|
}
|
|
|
|
Envelope<double> occi_datasource::envelope() const
|
|
{
|
|
return extent_;
|
|
}
|
|
|
|
layer_descriptor occi_datasource::get_descriptor() const
|
|
{
|
|
return desc_;
|
|
}
|
|
|
|
featureset_ptr occi_datasource::features(query const& q) const
|
|
{
|
|
if (env_ && pool_)
|
|
{
|
|
Envelope<double> const& box=q.get_bbox();
|
|
|
|
std::ostringstream s;
|
|
s << "select " << geometry_field_ << " as geom";
|
|
std::set<std::string> const& props=q.property_names();
|
|
std::set<std::string>::const_iterator pos=props.begin();
|
|
std::set<std::string>::const_iterator end=props.end();
|
|
while (pos != end)
|
|
{
|
|
s <<",\""<<*pos<<"\"";
|
|
++pos;
|
|
}
|
|
s << " from " << table_ << " where sdo_filter(" << geometry_field_ << ",";
|
|
s << " mdsys.sdo_geometry(" << SDO_GTYPE_2DPOLYGON << "," << srid_ << ",NULL,";
|
|
s << " mdsys.sdo_elem_info_array(1," << SDO_ETYPE_POLYGON << "," << SDO_INTERPRETATION_RECTANGLE << "),";
|
|
s << " mdsys.sdo_ordinate_array(";
|
|
s << std::setprecision(16);
|
|
s << box.minx() << "," << box.miny() << ", ";
|
|
s << box.maxx() << "," << box.maxy() << ")), 'querytype=WINDOW') = 'TRUE'";
|
|
|
|
#ifdef MAPNIK_DEBUG
|
|
clog << s.str() << endl;
|
|
#endif
|
|
|
|
return featureset_ptr(new occi_featureset(pool_,s.str(),desc_.get_encoding(),multiple_geometries_,props.size()));
|
|
}
|
|
|
|
return featureset_ptr();
|
|
}
|
|
|
|
featureset_ptr occi_datasource::features_at_point(coord2d const& pt) const
|
|
{
|
|
return featureset_ptr();
|
|
}
|
|
|