CVS: phpweather/db pw_db_common.php,NONE,1.1 pw_db_dba.php,NONE,1.1 pw_db_mysql.php,NONE,1.1 pw_db_n
Brought to you by:
iridium
Menu
▾
▴
CVS: phpweather/db pw_db_common.php,NONE,1.1 pw_db_dba.php,NONE,1.1 pw_db_mysql.php,NONE,1.1 pw_db_null.php,NONE,1.1 pw_db_pgsql.php,NONE,1.1 db_common.php,1.2,NONE db_dba.php,1.5,NONE db_mysql.php,1.5,NONE db_null.php,1.2,NONE db_pgsql.php,1.3,NONE
|
From: Martin G. <gim...@us...> - 2002-03-07 09:40:41
|
Update of /cvsroot/phpweather/phpweather/db
In directory usw-pr-cvs1:/tmp/cvs-serv10774
Added Files:
pw_db_common.php pw_db_dba.php pw_db_mysql.php pw_db_null.php
pw_db_pgsql.php
Removed Files:
db_common.php db_dba.php db_mysql.php db_null.php db_pgsql.php
Log Message:
Applied patch from Carsten Klapp <car...@ma...> - thanks a
lot. I also did some reformatting on some of the comments.
--- NEW FILE ---
<?php
/* This code makes sure that the file is only included once. */
if (defined('PW_DB_COMMON')) {
return;
} else {
define('PW_DB_COMMON', true);
}
require(PHPWEATHER_BASE_DIR . '/base_object.php');
/**
* Common class for all the database-types.
*
* It contains some properties most database-types need, like
* $is_connected, $link_id and $result_id.
*
* @author Martin Geisler <gim...@gi...>
* @version $Id: pw_db_common.php,v 1.1 2002/03/07 09:40:38 gimpster Exp $
*/
class pw_db_common extends base_object {
/**
* Maintains the status of the database-connection.
*
* @var boolean
* @access public
*/
var $is_connected;
/**
* contains the link_id used when querying.
*
* @var integer
* @access private
*/
var $link_id;
/**
* contains the result_id used when fetching rows from a result-set.
*
* @var integer
* @access private
*/
var $result_id;
/**
* Initializes the database-object.
*
* $is_connected, $link_id and $result_id is set to false, to
* indicate that we're not connected.
*
* @param array the initial properties of the object
* @see $is_connected, $link_id, $result_id
*/
function pw_db_common($input) {
/* We start by calling the parent constructor. */
$this->base_object($input);
/* We're not connected at first, so we set these variables to
indicate that. */
$this->is_connected = false;
$this->link_id = false;
$this->result_id = false;
}
}
?>
--- NEW FILE ---
<?php
/* This code makes sure that the file is only included once. */
if (defined('PW_DB_DBA')) {
return;
} else {
define('PW_DB_DBA', true);
}
require(PHPWEATHER_BASE_DIR . '/db/pw_db_common.php');
/**
* This class is the 'dba' database-type. This type of database is a
* wrapper itself, so you have to pass a handler to it as the index
* 'db_handler', when you create it.
*
* It implements all the methods necessary to insert, update and
* retrive METARs using a Berkeley DB style database. This is a
* file-based database, so you have to make sure that you have write
* access to the directory where you place the database.
*
* @author Martin Geisler <gim...@gi...>
* @version $Id: pw_db_dba.php,v 1.1 2002/03/07 09:40:38 gimpster Exp $
*/
class pw_db_dba extends pw_db_common {
/**
* A link ID to the stations database.
*
* We have to maintain a different link ID for each database used.
*
* @var integer
* @access private
*/
var $link_stations_id;
/**
* A link ID to the countries database.
*
* We have to maintain a different link ID for each database used.
*
* @var integer
* @access private
*/
var $link_countries_id;
/**
* Constructor.
*
* It just calls the parent constructor.
*
* @param array the initial properties of the object
*/
function pw_db_dba($input) {
/* We just call the parent constructor. */
$this->pw_db_common($input);
}
/**
* Gets the type of the database.
*
* @return string The type of the database, 'dba' in this case.
* @access public
*/
function get_type() {
return 'dba';
}
/**
* Establishes a connection to the database. It is assumed, that the
* database is already created.
*
* If there has already been made a connection to the database, this
* function just returns true, and nothing will be changed. This
* means that it is safe to call this instead of testing
* $is_connected.
*
* If $properties['db_pconnect'] is true, then a persistent
* connection will be established. $db_hostname is used as the path
* for the database.
*
* @return boolean Returns true, if a connection were established,
* false otherwise.
*
* @access public
*
* @see disconnect(), $is_connected
*/
function connect() {
if ($this->is_connected) {
return true;
}
if (!$this->properties['db_pconnect']) {
$this->is_connected = $this->link_id =
dba_open(PHPWEATHER_BASE_DIR . '/db/files/' .
$this->properties['db_metars'],
'w',
$this->properties['db_handler']);
$this->link_stations_id =
dba_open(PHPWEATHER_BASE_DIR . '/db/files/' .
$this->properties['db_stations'],
'r',
$this->properties['db_handler']);
$this->link_countries_id =
dba_open(PHPWEATHER_BASE_DIR . '/db/files/' .
$this->properties['db_countries'],
'r',
$this->properties['db_handler']);
} else {
$this->is_connected = $this->link_id =
dba_popen(PHPWEATHER_BASE_DIR . '/db/files/' .
$this->properties['db_metars'],
'w',
$this->properties['db_handler']);
$this->link_stations_id =
dba_popen(PHPWEATHER_BASE_DIR . '/db/files/' .
$this->properties['db_stations'],
'r',
$this->properties['db_handler']);
$this->link_countries_id =
dba_popen(PHPWEATHER_BASE_DIR . '/db/files/' .
$this->properties['db_countries'],
'r',
$this->properties['db_handler']);
}
return $this->is_connected;
}
/**
* Disconnects from the database.
*
* If we're already disconnected from the database, this function
* will just return true.
*
* @return boolean Since dba_close() doesn't return any value, this
* function always returns true.
* @access public
* @see connect(), $is_connected
*/
function disconnect() {
if ($this->is_connected) {
dba_close($this->link_id);
$this->is_connected = false;
}
return true;
}
/**
* Inserts a METAR into the database.
*
* @param string The ICAO of the station.
* @param string The raw METAR.
* @param integer A standard UNIX timestamp.
* @access public
* @see update_metar()
*/
function insert_metar($station, $metar, $timestamp) {
dba_insert($station, $metar . ':' . $timestamp, $this->link_id);
}
/**
* Updates an existing METAR in the database.
*
* @param string The ICAO of the station.
* @param string The raw METAR.
* @param integer A standard UNIX timestamp.
* @access public
* @see insert_metar()
*/
function update_metar($station, $metar, $timestamp) {
dba_replace($station, $metar . ':' . $timestamp, $this->link_id);
}
/**
* Gets a METAR form the database.
*
* @param string The ICAO of the station.
* @return array The raw METAR and UNIX timestamp as an array, in
* that order.
* @access public
*/
function get_metar($station) {
if (dba_exists($station, $this->link_id)) {
$row = dba_fetch($station, $this->link_id);
$this->debug("Returning this row from the DBA database:<br><code>$row</code>");
return explode(':', $row);
} else {
return false;
}
}
/**
* Translates an ICAO into a station name
*
* The boring ICAO (e.g. EKYT) is translated into something like
* 'Aalborg, Denmark'.
*
* @param string The ICAO one want's to translate.
* @return string The full name of the station, including country.
* @access public
*/
function lookup_icao($icao) {
if (dba_exists($icao, $this->link_stations_id)) {
list($name, $country) =
explode(':', dba_fetch($icao, $this->link_stations_id));
return "$name, $country";
} else {
return $icao;
}
}
/**
* Creates the necessary files.
*
* @return bool Returns true is the files were created, false
* otherwise.
* @access private
*/
function create_tables() {
/* The following code is taken from connect(). The difference is,
that all the databases are created and truncated by this code. */
if (!$this->properties['db_pconnect']) {
$this->is_connected = $this->link_id =
dba_open(PHPWEATHER_BASE_DIR . '/db/files/' .
$this->properties['db_metars'],
'n',
$this->properties['db_handler']);
$this->link_stations_id =
dba_open(PHPWEATHER_BASE_DIR . '/db/files/' .
$this->properties['db_stations'],
'n',
$this->properties['db_handler']);
$this->link_countries_id =
dba_open(PHPWEATHER_BASE_DIR . '/db/files/' .
$this->properties['db_countries'],
'n',
$this->properties['db_handler']);
} else {
$this->is_connected = $this->link_id =
dba_popen(PHPWEATHER_BASE_DIR . '/db/files/' .
$this->properties['db_metars'],
'n',
$this->properties['db_handler']);
$this->link_stations_id =
dba_popen(PHPWEATHER_BASE_DIR . '/db/files/' .
$this->properties['db_stations'],
'n',
$this->properties['db_handler']);
$this->link_countries_id =
dba_popen(PHPWEATHER_BASE_DIR . '/db/files/' .
$this->properties['db_countries'],
'n',
$this->properties['db_handler']);
}
return $this->is_connected;
}
/**
* Inserts the stations into the database.
*
* It is assumed that create_tables() has been called previously
* (and that it returned true).
*
* @param array This three-dimensional array starts with a list of
* contry-codes. For each country-code the ICAOs and corresponding
* locations in that particular country are listed as key => value
* pairs.
* @param array An associative array with country-codes as the keys
* and the names of the countries as the values.
* @return bool
* @access private
*/
function insert_stations($data, $countries) {
while(list($cc, $country) = each($countries)) {
while(list($icao, $location) = each($data[$cc])) {
/* We insert all the stations in a given country into the
database. */
dba_insert($icao, "$location:$country", $this->link_stations_id);
$icaos[] = $icao; /* We collect the ICAOs for later. */
}
/* Now that we've collected all the ICAOs in the country, lets
insert the country with it's data into the database. The name
of the country is seperated from the list of ICAOs by a
single semi-colon (;). The ICAOs are seperated by a normal
colon (:). */
dba_insert($cc,
$country . ';' . implode(':', $icaos),
$this->link_countries_id);
unset($icaos); /* We can now forget about the ICAOs. */
}
return true;
}
/**
* Returns a list of available countries.
*
* @return array An associative array with the country-codes as
* the keys and the names of the countries as the
* values.
* @access public
*/
function get_countries() {
if (!$this->connect()) {
return false;
}
$cc = dba_firstkey($this->link_countries_id); /* We need the first key. */
while ($data = dba_fetch($cc, $this->link_countries_id)) {
list($country) = explode(';', $data);
/* The above statement extracts the name of the country. It's
seperated from the ICAOs by a semi-colon (;) */
$countries[$cc] = $country;
$cc = dba_nextkey($this->link_countries_id);
}
asort($countries); // Let's sort the countries.
return $countries;
}
/**
* Returns an array of stations.
*
* @param string The country-code.
* @param string This parameter is passed by reference. The name
* of the country that corresponds to the
* country-code is stored here.
* @return array An associative array with the ICAO as the key
* and the name of the station as the values. The
* name of the country is not added to the name of
* the station.
* @access public
*/
function get_icaos($cc, &$country) {
if (!$this->connect()) {
return false;
}
/* The name of the country is seperated from the list of ICAOs by
* a single semi-colon (;) */
list($country, $icaos) =
explode(';', dba_fetch($cc, $this->link_countries_id));
/* The ICAOs are seperated by a normal colon (:) */
$icaos = explode(':', $icaos);
while (list(, $icao) = each($icaos)) {
list($location) =
explode(':', dba_fetch($icao, $this->link_stations_id));
$locations[$icao] = $location;
}
return $locations;
}
}
?>
--- NEW FILE ---
<?php
/* This code makes sure that the file is only included once. */
if (defined('PW_DB_MYSQL')) {
return;
} else {
define('PW_DB_MYSQL', true);
}
require(PHPWEATHER_BASE_DIR . '/db/pw_db_common.php');
/**
* This class is the 'mysql' database-type.
*
* It implements all the methods necessary to insert, update and retrive METARs using a MySQL database. You'll need access to a MySQL database to be able to use this object.
*
* @author Martin Geisler <gim...@gi...>
* @version $Id: pw_db_mysql.php,v 1.1 2002/03/07 09:40:38 gimpster Exp $
*/
class pw_db_mysql extends pw_db_common {
/**
* This constructor does nothing besides calling the parent constructor.
*
* @param array the initial properties of the object
*/
function pw_db_mysql($input) {
$this->pw_db_common($input);
}
/**
* Gets the type of the database.
*
* @return string The type of the database, 'mysql' in this case.
* @access public
*/
function get_type() {
return 'mysql';
}
/**
* Establishes a connection to the database.
*
* If there has already been made a connection to the database, this
* function just returns true, and nothing will be changed. This
* means that it is safe to call this instead of testing
* $is_connected. If $properties['db_pconnect'] is true, then a
* persistent connection will be established.
*
* @return boolean Returns true, if a connection were established,
* false otherwise.
* @access public
* @see disconnect()
*/
function connect() {
/* Connect to the MySQL server */
if ($this->is_connected) {
return true;
}
if (!$this->properties['db_pconnect']) {
$this->link_id = mysql_connect($this->properties['db_hostname'],
$this->properties['db_username'],
$this->properties['db_password']);
} else {
$this->link_id = mysql_pconnect($this->properties['db_hostname'],
$this->properties['db_username'],
$this->properties['db_password']);
}
if ($this->link_id) {
$this->is_connected = true;
$this->select_db();
} else {
$this->is_connected = false;
}
return $this->is_connected;
}
/**
* Disconnects from the database.
*
* If we're already disconnected from the database, this function
* will just return true.
*
* @return boolean If the disconnec was succesfull then it returns
* true, otherwise it returns false.
* @access public
* @see connect()
*/
function disconnect() {
if (!$this->is_connected || mysql_close($this->link_id)) {
$this->is_connected = false;
return true;
} else {
return false;
}
}
/**
* Selects a database.
*
* @return boolean Returns true on success, false otherwise.
* @access public
*/
function select_db() {
return mysql_select_db($this->properties['db_database'], $this->link_id);
}
/**
* Executes a SQL-query.
*
* $result_id is updated as well
*
* @param string The SQL-statement.
* @return boolean True on success, false otherwise.
* @access public
*/
function query($query) {
$this->result_id = mysql_query($query, $this->link_id) or
$this->error("SQL-statement failed: $query<br>MySQL said " .
mysql_error() . ' (' . mysql_errno() . ')');
return $this->result_id;
}
/**
* Fetches a row as an array from the database.
*
* @return array The next row from the result-set.
* @access public
*/
function fetch_row() {
return mysql_fetch_row($this->result_id);
}
/**
* Fetches a row as an associative array from the database.
*
* @return array The next row from the result-set, as an associative
* array.
* @access public
*/
function fetch_array() {
return mysql_fetch_array($this->result_id);
}
/**
* Returns the number of rows in the result-set.
*
* @return integer The number of rows in the current result-set.
* @access public
*/
function num_rows() {
return mysql_num_rows($this->result_id);
}
/**
* Inserts a METAR into the database.
*
* @param string The ICAO of the station.
* @param string The raw METAR.
* @param integer A standard UNIX timestamp.
* @access public
* @see update_metar()
*/
function insert_metar($icao, $metar, $timestamp) {
$this->query("INSERT INTO " . $this->properties['db_metars'] .
" SET icao = '$icao', metar = '$metar', " .
"timestamp = FROM_UNIXTIME($timestamp)");
}
/**
* Updates an existing METAR in the database.
*
* @param string The ICAO of the station.
* @param string The raw METAR.
* @param integer A standard UNIX timestamp.
* @access public
* @see insert_metar()
*/
function update_metar($icao, $metar, $timestamp) {
$this->query("UPDATE " . $this->properties['db_metars'] .
" SET metar = '$metar', " .
"timestamp = FROM_UNIXTIME($timestamp) " .
"WHERE icao = '$icao'");
}
/**
* Gets a METAR form the database.
*
* @param string The ICAO of the station.
* @return string The raw METAR as an array from the database.
* @access public
*/
function get_metar($icao) {
$this->query("SELECT metar, UNIX_TIMESTAMP(timestamp) FROM " .
$this->properties['db_metars'] . " WHERE icao = '$icao'");
return $this->fetch_row();
}
/**
* Creates the necessary tables in the database.
*
* @return bool Returns true if it could connect to the database,
* false otherwise.
* @access private
*/
function create_tables() {
if (!$this->connect()) {
return false; // Failure!
}
/* First we make a table for the METARs */
$this->query('DROP TABLE IF EXISTS ' . $this->properties['db_metars']);
$this->query('CREATE TABLE ' . $this->properties['db_metars'] . '(
icao varchar(4) NOT NULL,
metar varchar(255) NOT NULL,
timestamp timestamp(14),
PRIMARY KEY (icao),
UNIQUE icao (icao)
)');
/* Then we make a table for the stations. */
$this->query('DROP TABLE IF EXISTS ' . $this->properties['db_stations']);
$this->query('CREATE TABLE ' . $this->properties['db_stations'] . '(
icao varchar(4) NOT NULL,
name varchar(255) NOT NULL,
cc char(2) NOT NULL,
country varchar(128) NOT NULL,
PRIMARY KEY (icao),
UNIQUE icao (icao),
KEY cc (cc)
)');
return true; // Succes!
}
/**
* Translates an ICAO into a station name
*
* The boring ICAO (e.g. EKYT) is translated into something like
* 'Aalborg, Denmark'.
*
* @param string The ICAO one want's to translate.
* @return string The full name of the station, including country.
* @access public
*/
function lookup_icao($icao) {
$this->query('SELECT name, country FROM ' .
$this->properties['db_stations'] . " WHERE icao = '$icao'");
if ($this->num_rows()) {
$row = $this->fetch_row();
return "$row[0], $row[1]";
} else {
return $icao;
}
}
/**
* Inserts the stations into the database.
*
* It is assumed that create_tables() has been called previously
* (and that it returned true), so that the necessary tables are
* already created.
*
* @param array This three-dimensional array starts with a list of
* contry-codes. For each country-code the ICAOs and corresponding
* locations in that particular country are listed as key => value
* pairs.
* @param array An associative array with country-codes as the keys
* and the names of the countries as the values.
* @return bool
* @access private
*/
function insert_stations($data, $countries) {
if (!$this->connect()) {
return false;
}
while(list($cc, $country) = each($countries)) {
/* The country names might contain dangerous characters. */
$country = addslashes($country);
while(list($icao, $location) = each($data[$cc])) {
/* The station name might also be dangerous. */
$location = addslashes($location);
$this->query('INSERT INTO ' . $this->properties['db_stations'] .
" VALUES ('$icao', '$location', '$cc', '$country')");
}
}
return true;
}
/**
* Returns a list of available countries.
*
* @return array An associative array with the country-codes as the
* keys and the names of the countries as the values.
* @access public
*/
function get_countries() {
if (!$this->connect()) {
return false;
}
$this->query('SELECT DISTINCT cc, country FROM ' .
$this->properties['db_stations'] . ' ORDER BY country');
while($row = $this->fetch_row()) {
$rows[$row[0]] = $row[1];
}
return $rows;
}
/**
* Returns an array of stations.
*
* @param string The country-code.
* @param string This parameter is passed by reference. The name of
* the country that corresponds to the country-code is stored here.
* @return array An associative array with the ICAO as the key and
* the name of the station as the values. The name of the country is
* not added to the name of the station.
* @access public
*/
function get_icaos($cc, &$country) {
if (!$this->connect()) {
return false;
}
$this->query('SELECT icao, name, country FROM ' .
$this->properties['db_stations'] .
" WHERE cc = '$cc' ORDER BY name");
/* We have to do this manually the first time, so that we can set
$country */
list($icao, $name, $country) = $this->fetch_row();
$rows[$icao] = $name;
while(list($icao, $name) = $this->fetch_row()) {
$rows[$icao] = $name;
}
return $rows;
}
}
?>
--- NEW FILE ---
<?php
/* This code makes sure that the file is only included once. */
if (defined('PW_DB_NULL')) {
return;
} else {
define('PW_DB_NULL', true);
}
require(PHPWEATHER_BASE_DIR . '/db/pw_db_common.php');
/**
* This class is the 'null' database-type
*
* It pretends to be a database, but really it isn't :-) It just
* implements all the functions one would expect from a database, and
* then returns true or false or with empty strings and arrays as
* appropriate.
*
* @author Martin Geisler <gim...@gi...>
* @version $Id: pw_db_null.php,v 1.1 2002/03/07 09:40:38 gimpster Exp $
*/
class pw_db_null extends pw_db_common {
/**
* This constructor does nothing besides calling the parent constructor.
*
* @param array the initial properties of the object
*/
function pw_db_null($input) {
$this->pw_db_common($input);
}
/**
* Gets the type of the database.
*
* @return string The type of the database, 'null' in this case.
* @access public
*/
function get_type() {
return 'null';
}
/**
* Pretends to establish a connection to the database.
*
* Like all the other methods of this database object, this doesn't
* do anything useful.
*
* @return boolean Always returns true, so that other functions that
* depends on a connection to the database doesn't fail because of
* this.
* @access public
*/
function connect() {
return true;
}
/**
* Pretends to insert a METAR into the database.
*
* @param string The ICAO of the station.
* @param string The raw METAR.
* @param integer A standard UNIX timestamp.
* @access public
* @see update_metar()
*/
function insert_metar($station, $metar, $timestamp) {
;
}
/**
* Pretends to update an existing METAR in the database.
*
* @param string The ICAO of the station.
* @param string The raw METAR.
* @param integer A standard UNIX timestamp.
* @access public
* @see insert_metar()
*/
function update_metar($station, $metar, $timestamp) {
;
}
/**
* Pretends to return a METAR form the database.
*
* @param string The ICAO of the station.
* @return string Since we don't have a database, we just return an
* empty string.
* @access public
*/
function get_metar($station) {
return '';
}
/**
* Translates an ICAO into a station name
*
* @param string The ICAO to translate.
* @return string The translated ICAO.
* @access public
*/
function lookup_icao($icao) {
$linesize = 128;
$fp = fopen(PHPWEATHER_BASE_DIR . '/db/files/stations.db', 'r');
$result = '';
$left = 0;
$right = filesize(PHPWEATHER_BASE_DIR . '/db/files/stations.db')/$linesize;
while ($left < $right) {
fseek($fp, $linesize * round(($left+$right)/2));
$data = fgetcsv($fp, $linesize, ';');
if ($data[0] > $icao) {
$right = floor(($left+$right)/2);
} elseif ($data[0] < $icao) {
$left = ceil(($left+$right)/2);
} else {
$left = $right;
$result = trim($data[1]);
}
}
fclose($fp);
return $result;
}
/**
* Makes sure that it's possible to create the files.
*
* The method doesn't create any files, it just veryfies that it's
* we have write permission to PHPWEATHER_BASE_DIR/db.
* @return bool True if it's possible to create files.
* @access private
*/
function create_tables() {
return is_writable(PHPWEATHER_BASE_DIR . '/db');
}
/**
* Inserts the stations into the database.
*
* It is assumed that create_tables() has been called previously
* (and that it returned true), so that we can create the necessary
* files. insert_stations() populates PHPWEATHER_BASE_DIR/db/files/
* with a file for each country. The files contain PHP code, so that
* $country and $icaos will be set, if the file is included.
*
* @param array This three-dimensional array starts with a list of
* contry-codes. For each country-code the ICAOs and corresponding
* locations in that particular country are listed as key => value
* pairs.
* @param array An associative array with country-codes as the keys
* and the names of the countries as the values.
* @return bool
* @access private
*/
function insert_stations($data, $countries) {
while(list($cc, $country) = each($countries)) {
$fp = fopen(PHPWEATHER_BASE_DIR . "/db/files/$cc.php", 'w');
fputs($fp, "<?php\n/* File with stationnames in $countries[$cc] */\n\n");
fputs($fp, "\$country = '" . addslashes($countries[$cc]) . "';\n\n");
fputs($fp, "\$icaos = array(\n");
/* We do it ourselves the first time */
list($icao, $location) = each($data[$cc]);
fputs($fp, " '$icao' => '" . addslashes($location) . "'");
$stations[$icao] = "$location, $countries[$cc]";
while(list($icao, $location) = each($data[$cc])) {
fputs($fp, ",\n '$icao' => '" . addslashes($location) . "'");
$stations[$icao] = "$location, $countries[$cc]";
}
fputs($fp, "\n);\n\n?>\n");
fclose($fp);
}
/* We write a file with all the stations. Each line is 128 bytes
long so that it's easy to find a given station again. */
$fp = fopen(PHPWEATHER_BASE_DIR . '/db/files/stations.db', 'w');
if ($fp) {
ksort($stations);
reset($stations);
while(list($icao, $location) = each($stations)) {
$str = str_pad("$icao;$location", 127)."\n";
fputs($fp, $str);
}
fclose($fp);
}
/* We also write a file with all the countries. */
$fp = fopen(PHPWEATHER_BASE_DIR . '/db/files/countries.php', 'w');
if ($fp) {
fputs($fp, "<?php\n/* File with names of all countries. */\n\n\$countries = array(\n");
reset($countries);
list($cc, $country) = each($countries);
$country = addslashes($country);
fputs($fp, " '$cc' => '$country'");
while(list($cc, $country) = each($countries)) {
$country = addslashes($country);
fputs($fp, ",\n '$cc' => '$country'");
}
fputs($fp, "\n);\n\n?>\n");
fclose($fp);
}
return true;
}
/**
* Returns a list of available countries.
*
* It uses the file PHPWEATHER_BASE_DIR/db/files/countries.php
* created by insert_stations().
*
* @return array An associative array with the country-codes as the
* keys and the names of the countries as the values.
* @access public
*/
function get_countries() {
require_once(PHPWEATHER_BASE_DIR . '/db/files/countries.php');
return $countries;
}
/**
* Returns an array of stations.
*
* @param string The country-code.
* @param string This parameter is passed by reference. The name of
* the country that corresponds to the country-code is stored here.
* @return array An associative array with the ICAO as the key and
* the name of the station as the values. The name of the country is
* not added to the name of the station.
* @access public
*/
function get_icaos($cc, &$country) {
include(PHPWEATHER_BASE_DIR . "/db/files/$cc.php");
return $icaos;
}
}
?>
--- NEW FILE ---
<?php
/* This code makes sure that the file is only included once. */
if (defined('PW_DB_PGSQL')) {
return;
} else {
define('PW_DB_PGSQL', true);
}
require(PHPWEATHER_BASE_DIR . '/db/pw_db_common.php');
/**
* This class is the 'pgsql' database-type
*
* It implements all the methods necessary to insert, update and
* retrive METARs using a PostgreSQL database.
*
* @author Kristian Kristensen <co...@zi...>
* @version $Id: pw_db_pgsql.php,v 1.1 2002/03/07 09:40:38 gimpster Exp $
*/
class pw_db_pgsql extends pw_db_common {
/**
* This constructor does nothing besides calling the parent constructor.
*
* @param array the initial properties of the object
*/
function pw_db_pgsql($input = array()) {
$this->pw_db_common($input);
}
/**
* Gets the type of the database.
*
* @return string The type of the database, 'pgsql' in this case.
* @access public
*/
function get_type() {
return 'pgsql';
}
/**
* Establishes a connection to the database.
*
* If there has already been made a connection to the database, this
* function just returns true, and nothing will be changed. This
* means that it is safe to call this instead of testing
* $is_connected. If $properties['db_pconnect'] is true, then a
* persistent connection will be established.
*
* @return boolean Returns true, if a connection were established,
* false otherwise.
* @access public
* @see disconnect()
*/
function connect() {
/* Connect to the PostgreSQL server */
if ($this->is_connected) {
return true;
}
if (!$this->properties['db_pconnect']) {
$this->link_id = pgsql_connect($this->properties['db_database']);
} else {
$this->link_id = pgsql_pconnect($this->properties['db_database']);
}
if ($this->link_id) {
$this->is_connected = true;
$this->select_db();
} else {
$this->is_connected = false;
}
return $this->is_connected;
}
/**
* Disconnects from the database.
*
* If we're already disconnected from the database, this function
* will just return true.
*
* @return boolean If the disconnec was succesfull then it returns
* true, otherwise it returns false.
* @access public
* @see connect()
*/
function disconnect() {
if (!$this->is_connected || pg_close($this->link_id)) {
$this->is_connected = false;
return true;
} else {
return false;
}
}
/**
* Selects a database.
*
* @return boolean Returns true on success, false otherwise.
* @access public
*/
function select_db() {
if ($this->is_connected) {
return true;
} else {
return false;
}
}
/**
* Executes a SQL-query.
*
* $result_id is updated as well
*
* @param string The SQL-statement.
* @return boolean True on success, false otherwise.
* @access public
*/
function query($query) {
return ($this->result_id = pg_exec( $this->link_id, $query));
}
/**
* Fetches a row as an array from the database.
*
* @return array The next row from the result-set.
* @access public
*/
function fetch_row() {
return pg_fetch_row($this->result_id,0);
}
/**
* Fetches a row as an associative array from the database.
*
* @return array The next row from the result-set, as an associative
* array.
* @access public
*/
function fetch_array() {
return pg_fetch_array($this->result_id,0);
}
/**
* Returns the number of rows in the result-set.
*
* @return integer The number of rows in the current result-set.
* @access public
*/
function num_rows() {
return pg_numrows($this->result_id);
}
/**
* Inserts a METAR into the database.
*
* @param string The ICAO of the station.
* @param string The raw METAR.
* @param integer A standard UNIX timestamp.
* @access public
* @see update_metar()
*/
function insert_metar($station, $metar, $timestamp) {
$this->query('INSERT INTO ' . $this->properties['db_metars'] .
" SET station = '$station', metar = '$metar', " .
"timestamp = FROM_UNIXTIME($timestamp)");
}
/**
* Updates an existing METAR in the database.
*
* @param string The ICAO of the station.
* @param string The raw METAR.
* @param integer A standard UNIX timestamp.
* @access public
* @see insert_metar()
*/
function update_metar($station, $metar, $timestamp) {
$this->query('UPDATE ' . $this->properties['db_metars'] .
" SET metar = '$metar', timestamp = '$timestamp' " .
"WHERE station = '$station'");
}
/**
* Gets a METAR form the database.
*
* @param string The ICAO of the station.
* @return string The raw METAR as an array from the database.
* @access public
*/
function get_metar($station) {
$this->query('SELECT metar, timestamp FROM ' .
$this->properties['db_metars'] .
" WHERE station = '$station'");
return $this->fetch_row();
}
}
?>
--- db_common.php DELETED ---
--- db_dba.php DELETED ---
--- db_mysql.php DELETED ---
--- db_null.php DELETED ---
--- db_pgsql.php DELETED ---
|
