<?php
|
class LtDbConnectionAdapterMysqli implements LtDbConnectionAdapter
|
{
|
public function connect($connConf)
|
{
|
return new mysqli($connConf["host"], $connConf["username"], $connConf["password"], $connConf["dbname"], $connConf["port"]);
|
}
|
|
public function exec($sql, $connResource)
|
{
|
$connResource->query($sql);
|
return $connResource->affected_rows;
|
}
|
|
public function query($sql, $connResource)
|
{
|
$rows = array();
|
$result = $connResource->query($sql);
|
while($row = $result->fetch_assoc())
|
{
|
$rows[] = $row;
|
}
|
return $rows;
|
}
|
|
public function lastInsertId($connResource)
|
{
|
return $connResource->insert_id;
|
}
|
|
public function escape($sql, $connResource)
|
{
|
return mysqli_real_escape_string($connResource, $sql);
|
}
|
}
|