X-Git-Url: http://git.shiar.net/minimedit.git/blobdiff_plain/ce6d14a5ee9d14d5573798e635e1ffe47cf65602..f988982ad609256e3bbbb8a41ca7c7b0b3b4fb74:/database.inc.php

diff --git a/database.inc.php b/database.inc.php
index 6a82507..464126b 100644
--- a/database.inc.php
+++ b/database.inc.php
@@ -8,7 +8,10 @@ class DB
 
 	function __construct($config, $options = [])
 	{
-		$options += [ PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION ];
+		$options += [
+			PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
+			PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_OBJ,
+		];
 		$this->dbh = new PDO($config, NULL, NULL, $options);
 	}
 
@@ -19,13 +22,24 @@ class DB
 		return $stmt;
 	}
 
+	function _value($val, &$params)
+	{
+		$params[] = $val;
+		return '?';
+	}
+
 	function insert($table, $row)
 	{
+		$params = [];
+		$cols = [];
+		foreach ($row as $col => $val) {
+			$cols[] = $this->_value($val, $params);
+		}
 		$sql = sprintf('INSERT INTO %s (%s) VALUES (%s)',
 			'"'.$table.'"',
 			implode(', ', array_keys($row)),
-			implode(', ', array_fill(0, count($row), '?'))
+			implode(', ', $cols)
 		);
-		return $this->query($sql, array_values($row));
+		return $this->query($sql, $params);
 	}
 }