<?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); } }