--- /dev/null
+<?php
+/**
+ * Mysql implementation for storing/searching geo location data for events.
+ * Makes use of the GIS extensions available in mySQL 4.1 and later.
+ *
+ * Copyright 2009 The Horde Project (http://www.horde.org/)
+ *
+ * See the enclosed file COPYING for license information (GPL). If you
+ * did not receive this file, see http://www.fsf.org/copyleft/gpl.html.
+ *
+ * @author Michael J. Rubinsky <mrubinsk@horde.org>
+ *
+ * @package Kronolith
+ */
+class Kronolith_Driver_Geo_Mysql extends Kronolith_Driver_Geo_Sql
+{
+ // Rouughly 69 miles per distance unit
+ private $_conversionFactor = 69;
+
+ /**
+ * Set the location of the specified event _id
+ *
+ * @see kronolith/lib/Driver/Kronolith_Driver_Geo#setLocation($event_id, $point)
+ */
+ public function setLocation($event_id, $point)
+ {
+ /* First make sure it doesn't already exist */
+ $sql = "SELECT COUNT(*) FROM kronolith_events_geo WHERE event_id = ('" . $event_id . "')";
+ $count = $this->_db->getOne($sql);
+ if ($count instanceof PEAR_Error) {
+ throw new Horde_Exception($count->getMessage());
+ }
+ /* INSERT or UPDATE */
+ if ($count) {
+ $sql = "UPDATE kronolith_events_geo SET coordinates = GeomFromText('POINT(" . $point['lat'] . " " . $point['lng'] . ")') WHERE event_id = '" . $event_id . "'";
+ } else {
+ $sql = "INSERT into kronolith_events_geo (event_id, coordinates) VALUES('" . $event_id . "', GeomFromText('POINT(" . $point['lat'] . " " . $point['lng'] . ")'))";
+ }
+ $result = $this->_write_db->query($sql);
+ if ($result instanceof PEAR_Error) {
+ throw new Horde_Exception($result->getMessage());
+ }
+
+ return $result;
+ }
+
+ /**
+ * Get the location of the provided event_id.
+ *
+ * @see kronolith/lib/Driver/Kronolith_Driver_Geo#getLocation($event_id)
+ */
+ public function getLocation($event_id)
+ {
+ $sql = "SELECT x(coordinates) as lat, y(coordinates) as lng FROM kronolith_events_geo WHERE event_id = '" . $event_id . "'";
+ $result = $this->_db->getRow($sql, null, DB_FETCHMODE_ASSOC);
+ if ($result instanceof PEAR_Error) {
+ throw new Horde_Exception($result->getMessage());
+ }
+ return $result;
+ }
+
+ /**
+ * Search for events "close to" a given point.
+ *
+ * TODO: If all we really use the geodata for is distance, it really doesn't
+ * make sense to use the GIS extensions since the distance calculations
+ * are done with Euclidian geometry ONLY ... and therefore will give
+ * incorrect results when done on a geocentric coordinate system...
+ * They might be useful if we eventually want to do searches on
+ * MBRs
+ *
+ * @see kronolith/lib/Driver/Kronolith_Driver_Geo#search($criteria)
+ */
+ public function search($criteria)
+ {
+ $point = $criteria['point'];
+ $limit = empty($criteria['limit']) ? 10 : $criteria['limit'];
+ $radius = empty($criteria['radius']) ? 10 : $criteria['radius'];
+
+ /* Allow overriding the default conversion factor */
+ $factor = empty($criteria['factor']) ? $this->_conversionFactor : $criteria['factor'];
+
+ // ... if this works it will be a miracle ;)
+ $sql = "SELECT event_id, "
+ . "GLength(LINESTRINGFromWKB(LineString(coordinates, GeomFromText('POINT(" . $point['lat'] . " " . $point['lng'] . ")')))) * " . $factor . " as distance, "
+ . "x(coordinates) as lat, y(coordinates) as lng FROM kronolith_events_geo HAVING distance < " . $radius . " ORDER BY distance ASC LIMIT " . $limit;
+
+ $results = $this->_db->getAssoc($sql, false, null, DB_FETCHMODE_ASSOC);
+ if ($results instanceof PEAR_Error) {
+ throw new Horde_Exception($results->getMessage());
+ }
+
+ return $results;
+
+ }
+}
\ No newline at end of file
--- /dev/null
+<?php
+/**
+ * General SQL implementation for storing/searching geo location data for events.
+ *
+ * Copyright 2009 The Horde Project (http://www.horde.org/)
+ *
+ * See the enclosed file COPYING for license information (GPL). If you
+ * did not receive this file, see http://www.fsf.org/copyleft/gpl.html.
+ *
+ * @author Michael J. Rubinsky <mrubinsk@horde.org>
+ *
+ * @package Kronolith
+ */
+class Kronolith_Driver_Geo_Sql extends Kronolith_Driver_Geo
+{
+ protected $_write_db;
+ protected $_db;
+
+ /**
+ * Still needs to return a PEAR_Error since Kronolith_Driver still expects it
+ *
+ * @return mixed boolean || PEAR_Error
+ */
+ public function initialize()
+ {
+ Horde::assertDriverConfig($this->_params, 'calendar', array('phptype'));
+
+ if (!isset($this->_params['database'])) {
+ $this->_params['database'] = '';
+ }
+ if (!isset($this->_params['username'])) {
+ $this->_params['username'] = '';
+ }
+ if (!isset($this->_params['hostspec'])) {
+ $this->_params['hostspec'] = '';
+ }
+ if (!isset($this->_params['table'])) {
+ $this->_params['table'] = 'kronolith_events_geo';
+ }
+
+ /* Connect to the SQL server using the supplied parameters. */
+ $this->_write_db = DB::connect($this->_params,
+ array('persistent' => !empty($this->_params['persistent']),
+ 'ssl' => !empty($this->_params['ssl'])));
+ if (is_a($this->_write_db, 'PEAR_Error')) {
+ return $this->_write_db;
+ }
+ $this->_initConn($this->_write_db);
+
+ /* Check if we need to set up the read DB connection
+ * seperately. */
+ if (!empty($this->_params['splitread'])) {
+ $params = array_merge($this->_params, $this->_params['read']);
+ $this->_db = DB::connect($params,
+ array('persistent' => !empty($params['persistent']),
+ 'ssl' => !empty($params['ssl'])));
+ if (is_a($this->_db, 'PEAR_Error')) {
+ return $this->_db;
+ }
+ $this->_initConn($this->_db);
+ } else {
+ /* Default to the same DB handle for the writer too. */
+ $this->_db = $this->_write_db;
+ }
+
+ return true;
+ }
+
+ protected function _initConn(&$db)
+ {
+ // Set DB portability options.
+ switch ($db->phptype) {
+ case 'mssql':
+ $db->setOption('portability', DB_PORTABILITY_LOWERCASE | DB_PORTABILITY_ERRORS | DB_PORTABILITY_RTRIM);
+ break;
+ default:
+ $db->setOption('portability', DB_PORTABILITY_LOWERCASE | DB_PORTABILITY_ERRORS);
+ }
+
+ /* Handle any database specific initialization code to run. */
+ switch ($db->dbsyntax) {
+ case 'oci8':
+ $query = "ALTER SESSION SET NLS_DATE_FORMAT = 'YYYY-MM-DD HH24:MI:SS'";
+
+ /* Log the query at a DEBUG log level. */
+ Horde::logMessage(sprintf('Kronolith_Driver_Sql::_initConn(): user = "%s"; query = "%s"',
+ Horde_Auth::getAuth(), $query),
+ __FILE__, __LINE__, PEAR_LOG_DEBUG);
+
+ $db->query($query);
+ break;
+
+ case 'pgsql':
+ $query = "SET datestyle TO 'iso'";
+
+ /* Log the query at a DEBUG log level. */
+ Horde::logMessage(sprintf('Kronolith_Driver_Sql::_initConn(): user = "%s"; query = "%s"',
+ Horde_Auth::getAuth(), $query),
+ __FILE__, __LINE__, PEAR_LOG_DEBUG);
+
+ $db->query($query);
+ break;
+ }
+ }
+
+ /**
+ * Set the location of the specified event _id
+ *
+ * @see kronolith/lib/Driver/Kronolith_Driver_Geo#setLocation($event_id, $point)
+ */
+ public function setLocation($event_id, $point)
+ {
+ /* First make sure it doesn't already exist */
+ $sql = "SELECT COUNT(*) FROM kronolith_events_geo WHERE event_id = ('" . $event_id . "')";
+ $count = $this->_db->getOne($sql);
+ if ($count instanceof PEAR_Error) {
+ throw new Horde_Exception($count->getMessage());
+ }
+
+ /* INSERT or UPDATE */
+ $params = array($point['lat'], $point['lng'], $event_id);
+ if ($count) {
+ $sql = 'UPDATE kronolith_events_geo SET event_lat = ?, event_lng = ? WHERE event_id = ?';
+ } else {
+ $sql = 'INSERT into kronolith_events_geo (event_lat, event_lng, event_id) VALUES(?, ?, ?)';
+ }
+ $result = $this->_write_db->query($sql, $params);
+ if ($result instanceof PEAR_Error) {
+ throw new Horde_Exception($result->getMessage());
+ }
+
+ return $result;
+ }
+
+ /**
+ * Get the location of the provided event_id.
+ *
+ * @see kronolith/lib/Driver/Kronolith_Driver_Geo#getLocation($event_id)
+ */
+ public function getLocation($event_id)
+ {
+ $sql = 'SELECT event_lat as lat, event_lng as lng FROM kronolith_events_geo WHERE event_id = ?';
+ $result = $this->_db->getRow($sql, array($event_id), DB_FETCHMODE_ASSOC);
+ if ($result instanceof PEAR_Error) {
+ throw new Horde_Exception($result->getMessage());
+ }
+
+ return $result;
+ }
+
+ /**
+ *
+ * @see kronolith/lib/Driver/Kronolith_Driver_Geo#removeLocation($event_id)
+ */
+ public function removeLocation($event_id)
+ {
+ $sql = 'DELETE FROM kronolith_events_geo WHERE event_id = ?';
+ $this->_write_db->query($sql, array($event_id));
+ }
+
+ /**
+ * Search for events "close to" a given point.
+ *
+ * TODO: If all we really use the geodata for is distance, it really doesn't
+ * make sense to use the GIS extensions since the distance calculations
+ * are done with Euclidian geometry ONLY ... and therefore will give
+ * incorrect results when done on a geocentric coordinate system...
+ * They might be useful if we eventually want to do searches on
+ * MBRs
+ *
+ * @see kronolith/lib/Driver/Kronolith_Driver_Geo#search($criteria)
+ */
+ public function search($criteria)
+ {
+ throw new Horde_Exception(_("Searching requires a GIS enabled database."));
+ }
+}
\ No newline at end of file
projects / horde.git / commitdiff