Forums PostgreSQL.fr

 
//print_r($tab);
       foreach($tab as $cle=>$valeur)
       {
            $tabVal[$cle] = array('type_id'=>$cle,'import_time'=>strval($valeur));
      
       }

<?php 
class BaseDBAccess
{
    var $sDriver='';
    var $sHost='';
    var $sDatabase='';
    var $sUser='';
    var $sPassword='';
    private static $oDatabase;
	var $oPdo=null;
	var $sQuery='';
	var $oPDOStatement=null;
	
 
    /**
     * Constructor for database connection
	 * @param string $sDriver
	 * @param string $sHost
	 * @param string $sDatabase
	 * @param string $sUser
	 * @param string $sPassword
	 */
     private function __construct($sDriver='',$sHost='',$sDatabase='',$sUser='',$sPassword='')
     {
	     	try{
				$this->setDriver($sDriver);
				$this->setHost($sHost);
				$this->setDatabase($sDatabase);
				$this->setUser($sUser);
				$this->setPassword($sPassword);
				$sDrive = $this->sDriver.':dbname='.$this->sDatabase.";host=".$this->sHost;
				$this->oPdo=new PDO($sDrive, $this->sUser, $this->sPassword);
				$this->oPdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
			}catch(PDOException $e){
				echo 'Erreur : '.$e->getMessage().'<br />';
    			echo 'N° : '.$e->getCode();	
			}
			return $this->oPdo;
     }
        
        
	/**
	 * Method for setting all variables
	 * @return unknown_type
	 */
    public function setDriver($sDriver){
			$this->sDriver=$sDriver;
	}
	
	public function setHost($sHost){
			$this->sHost=$sHost;
	}
	
	public function setDatabase($sDatabase){
			$this->sDatabase=$sDatabase;
	}
	
	public function setUser($sUser){
			$this->sUser=$sUser;
	}
	
	public function setPassword($sPassword){
			$this->sPassword=$sPassword;
	}
	
	public function setQuery($sQuery){
			$this->sQuery=$sQuery;
	}
	
	protected function setPdo($oPdo){
			$this->oPdo=$oPdo;
	}  
        
	/**
	 * To get instance of Database
	 *
	 * @param string $sDriver
	 * @param string $sHost
	 * @param string $sDatabase
	 * @param string $sUser
	 * @param string $sPassword
	 * @return Database object
	 */
	public static function getInstance($sDriver='',$sHost='',$sDatabase='',$sUser='',$sPassword=''){
		if(is_null(self::$oDatabase)){
			self::$oDatabase = new BaseDBAccess($sDriver,$sHost,$sDatabase,$sUser,$sPassword);
		}
		return self::$oDatabase;
	}   
        
 
	/**
	 *  Initiates a transaction
	* @return <bool>  */
	public function beginTransaction()
	{
		return $this->oPdo->beginTransaction();
	}
	
	
	
	/* Commits a transaction
	@return <bool> */
	public function commit()
	{
		return $this->oPdo->commit();
	}
	
	/* Commits a transaction
	@return <bool> */
	public function prepared($oPDOStatement)
	{
		$this->oPDOStatement =$oPDOStatement;
		return $this->oPdo->prepare($oPDOStatement);
	}
	
	
	/* Fetch the SQLSTATE associated with the
	last operation on the database handle
	* @return <string> */
	public function errorCode()
	{
		return $this->oPdo->errorCode();
	}
	
	/* Fetch extended error information associated with
	the last operation on the database handle
	@return <array> */
	public function erroInfo()
	{
		return $this->oPdo->errorInfo();
	}
	
	/* Executes an SQL statement, return the number of affected row
	@param <String> $statement
	@return <int> */
	public function exec($statement)
	{
		return $this->oPdo->exec($statement);
	}   
	
	/* Rolls back a transaction
	@return <bool> */
	public function rollBack()
	{
		return $this->oPdo->rollBack();
	}
	
	public function lastInsertId()
	{
		return $this->oPdo->lastInsertId();
	}
	
      
 } /*** end of class ***/
 
 
?>

<?php 
require_once ("BaseDBAccess.php");
class PostgresqlDBAccess extends BaseDBAccess
{
	var $PgsqlConnection = '';
	var $seq;
	
	public function __construct()
	{
	   // $this->PgsqlConnectDb();
	}
	
	public function PgsqlConnectDb()
	{
		$this->PgsqlConnection = $PgsqlConnection;
		$this->PgsqlConnection = BaseDBAccess::getInstance('pgsql','localhost','mabase','postgres','admin');
		return $this->PgsqlConnection;	
	}
	
	 /**
      * @Insert a value into a table
      * @acces public
      * @param string $table
      * @param array $values
      * @return int The last Insert Id on success or throw PDOexeption on failure
      */
	public function insert($table,$value)
	{	
	 	$this->PgsqlConnectDb();
	    /*** snarg the field names from the first array member ***/
        $fieldnames = array_keys($value[0]);
           
        /*** now build the query ***/
        $size = sizeof($fieldnames);
        $i = 1;
        $sql = "INSERT INTO $table";
            
        /*** set the field names ***/
        $fields = '( ' . implode(' ,', $fieldnames) . ' )';
        /*** set the placeholders ***/
        $bound = '(:' . implode(', :', $fieldnames) . ' )';
        /*** put the query together ***/
        $sql .= $fields.' VALUES '.$bound;
          
        /*** prepare and execute ***/
        $stmt = $this->PgsqlConnection->prepared($sql);
          
        try
        {
	           		 foreach($value as $vals)
	        		 {
		        		 	$this->PgsqlConnection->beginTransaction(); 
		           		 	$stmt->execute($vals);
		           		 	$this->PgsqlConnection->commit();
		           		 	$lastid = $this->PgsqlConnection->lastInsertId();
		           		 	var_dump($lastid);
	           		 }
        }catch(PDOException $e){
           		 			$this->PgsqlConnection->rollback();
           		 			echo 'Erreur : '.$e->getMessage().'<br />';
   							echo 'N° : '.$e->getCode();
   						
        }
	}
	
   
}
 /*** end of class ***/
 
 
?>

class Serializer
{
	// Variable for XML object
	var $urlXML;
	var $host;
	var $username;
	var $password;
	var $port;
	var $dbname;
	var $error = null;
    var $dbconnect;
    var $query;
    var $result;
    var $persistent;

	//Constructor
	public function __construct()
	{
            $this->Connect(); 
	}
	
	//method for connecting into the database
	public function Connect ($Db="evostream_logs",$Host="127.0.0.1",$PgPort=5432,$User="postgres",$pass="admin",$persist=0)
    {
		// Passed the variable to objet
    	$this->dbname=$Db;
		$this->host=$Host;
		$this->port=$PgPort;
		$this->username=$User;
		$this->password=$pass;
		$this->persistent=$persist;
            
    	$connect="host='".$this->host."' port='".$this->port."' dbname='".$this->dbname."' user='".$this->username."'";
            
        // if password is not empty
    	if (!empty($this->password))
        {
          		$connect.=" password=".$this->password;
        }  
        
        //Connection persistent
        if ($this->persistent)
        {
                $this->dbconnect=pg_pconnect($connect);
        }else{
                $this->dbconnect=pg_connect($connect);
        }        

        //if not connected
        if (!$this->dbconnect)
        {
                $this->error="cannot connect to database ".$this->dbname;
        }        
    }