我刚刚将数据库从mysql迁移到postgresql。以及我使用PDO的代码。我已经搜索了如何使用PDO连接到postgresql,它是有效的。但当调用函数创建数据和读取数据时,我遇到了麻烦。我的代码中总是出现"无法创建数据"的警告。
但当我调用search函数时,postgresql中的数据就出来了。请帮我解决这个问题。
这是代码:
class barang.php
<?php
class Barang
{
// database connection and table name
private $conn;
private $table_name = "barang";
// object properties
public $id_barang;
public $nama_barang;
public $harga_satuan;
public function __construct($db){
$this->conn = $db;
}
// create barang
function create(){
// to get time-stamp for 'created' field
//write query
$query = "INSERT INTO
" . $this->table_name . "
id_barang = ?, nama_barang = ? , harga_satuan = ?";
$stmt = $this->conn->prepare($query);
$stmt->bindParam(1, $this->id_barang);
$stmt->bindParam(2, $this->nama_barang);
$stmt->bindParam(3, $this->harga_satuan);
if($stmt->execute()){
return true;
}else{
return false;
}
}
// read products
function readAll($page, $from_record_num, $records_per_page)
{
$query = "SELECT
id_barang, nama_barang, harga_satuan
FROM
" . $this->table_name . "
ORDER BY
id_barang
LIMIT
{$from_record_num}, {$records_per_page}";
$stmt = $this->conn->prepare( $query );
$stmt->execute();
return $stmt;
}
function Search()
{
$query = "SELECT
id_barang, nama_barang, harga_satuan
FROM
" . $this->table_name . "
WHERE
id_barang LIKE :search OR nama_barang LIKE :search ";
$stmt = $this->conn->prepare($query);
$search = $_GET['search'];
$stmt->bindValue(':search','%' . $search . '%', PDO::PARAM_STR);
$stmt->execute();
return $stmt;
}
}
?>
警报无法在此代码上创建数据捕获:
$database = new Database();
$db = $database->getConnection();
// if the form was submitted
if($_POST)
{
// instantiate barang object
include 'objects/barang.php';
$barang = new Barang($db);
// set barang property values
$barang->id_barang = $_POST['id_barang'];
$barang->nama_barang = $_POST['nama_barang'];
$barang->harga_satuan = $_POST['harga_satuan'];
// create the barang
if($barang->create()){
echo "<div class='"alert alert-success alert-dismissable'">";
echo "<button type='"button'" class='"close'" data-dismiss='"alert'" aria-hidden='"true'">×</button>";
echo "Data barang was created.";
echo "</div>";
}
// if unable to create the barang, tell the user
else{
echo "<div class='"alert alert-danger alert-dismissable'">";
echo "<button type='"button'" class='"close'" data-dismiss='"alert'" aria-hidden='"true'">×</button>";
echo "Unable to create barang.";
echo "</div>";
}
column=value
系列的insert语句不是标准SQL,它是MySQL特定的语法,PostgreSQL不支持这种语法。您应该使用ANSI-SQL语法:
$query = "INSERT INTO
" . $this->table_name . "
(id_barang, nama_barang , harga_satuan) VALUES (?, ?, ?)";
编辑:
MySQL使用的limit
子句也不是标准的。在PostgreSQL中,语法略有不同:
$query = "SELECT
id_barang, nama_barang, harga_satuan
FROM
" . $this->table_name . "
ORDER BY
id_barang
LIMIT
{$records_per_page}"
OFFSET
{$from_record_num};