<?php

global $connection;

/**
 *  db_connect() -  Connect to the database 
 */
function db_connect() {

        global $connection;

        if ($connection != null) {
                return $connection;
        }

        try {
                $connection = mysql_connect('localhost', 'user', 'password');
                return $connection;
        } catch ( Exception $e ) {
                error_log($e->getMessage());
                return null;
        }
}


function query_select_execute($query) {
        $connection = db_connect();
        $results = array();
        mysql_select_db('db', $connection);
        $rs = mysql_query($query, $connection);

        while ($row = mysql_fetch_assoc($rs)) {
                $results[] = $row; 
        }

        close_connection();
        return $results;
}

function query_update_execute($query) {
        $connection = db_connect();
        $results = array();
        mysql_select_db('db', $connection);
        $rs = mysql_query($query, $connection);
        error_log("result :".$rs);
        error_log("erreur :".mysql_error($connection));

        close_connection();
}


function close_connection() {
        global $connection;
        return mysql_close($connection);
}

?>