无法使用PDO SQLSRV将数据插入SQL db
问题描述 投票：0回答：1
我正在尝试学习为SQL Server数据库创建一个简单的CRUD API。现在，我仅设法从数据库中选择表，现在我继续将数据插入数据库中。
但是我在使用PDO SQLSRV将值插入本地SQL Server数据库时遇到问题。请指导我修复代码。
仅供参考，我的sql表仅使用nvarchar，datetime，int和numeric数据类型。
表结构
AcCustomerID | nvarchar(20)
AcCustomerName | nvarchar(100)
AcTermID | nvarchar(20)
AcAreaID | nvarchar(20)
AcCusGroupID | nvarchar(20)
AcCusUDGroupID | nvarchar(20)
BillingAddress1 | nvarchar(100)
BillingAddress2 | nvarchar(100)
BillingAddress3 | nvarchar(100)
BillingAddress4 | nvarchar(100)
BillingTel1 | nvarchar(100)
BillingTel2 | nvarchar(100)
BillingFax1 | nvarchar(100)
BillingFax2 | nvarchar(100)
BillingPostalCode | nvarchar(10)
BillingContact1 | nvarchar(100)
BillingContact2 | nvarchar(100)
BillingEmail | nvarchar(100)
BillingHomePage | nvarchar(100)
IsActive | nvarchar(1)
Notes | nvarchar(MAX)
CreateBy | nvarchar(20)
CreateDate | datetime
EditBy | nvarchar(20)
EditDate | datetime
Stamp | int
AcCustomerNickName | nvarchar(100)
DateOfBirth | datetime
IsMember | nvarchar(1)
Gender | nvarchar(1)
MemberNo | nvarchar(100)
MobileNo | nvarchar(100)
IdentityNo | nvarchar(100)
MemberJoinDate | datetime
MemberExpireDate | datetime
MemberMarriageDate | datetime
AcMemberEthnicID | nvarchar(20)
AcMemberIncomeID | nvarchar(20)
AcMemberOccupationID | nvarchar(20)
MemberPointBalance | numeric(18, 2)
MemberPointAccumulated | numeric(18, 4)
PriceCode | nvarchar(1)
AcSalesmanID | nvarchar(20)
IsGSTRegister | nvarchar(1)
GSTRegisterNumber | nvarchar(30)
BusinessRegisterNumber | nvarchar(30)
AcCurrencyID | nvarchar(5)
IsAllowPrintStatement | nvarchar(1)
IsAllowExceedCreditTerm | nvarchar(1)
IsAllowExceedCreditLimit| nvarchar(1)
LocalCreditLimit | numeric(18, 2)
LocalBalanceAmount | numeric(18, 2)
AcTaxID | nvarchar(20)
IsAllowCreditSalesForPOS| nvarchar(1)
MemberNotes | nvarchar(MAX)
AcINCardPackageID | nvarchar(20)
AcCustomerIDParentID | nvarchar(20)
TaxSLTRegistrationNo | nvarchar(40)
TaxSVTRegistrationNo | nvarchar(40)
AcTaxIDSST | nvarchar(20)
SSTExemptionCertNumber | nvarchar(30)
config / database.php
<?php
class Database
{
// specify your own database credentials
private $host = "localhost\QNEBSS";
private $db_name = "cafe99";
private $username = "sa";
private $password = "QnE123!@#";
public $conn;
// get the database connection
public function getConnection()
{
$this->conn = null;
try
{
$this->conn = new PDO("sqlsrv:Server=".$this->host.";Database=".$this->db_name, $this->username, $this->password);
$this->conn->exec("set names utf8");
}
catch(PDOException $exception)
{
echo json_encode(array("message" => "Connection error: " . $exception->getMessage()));
}
return $this->conn;
}
}
?>
objects / customer.php
<?php
class Customer
{
// database connection and table name
private $conn;
private $table_name = "AcCustomer";
// object properties
public $AcCustomerID, $AcCustomerName, $AcTermID, $AcAreaID, $AcCusGroupID, $AcCusUDGroupID,
$BillingAddress1, $BillingAddress2, $BillingAddress3, $BillingAddress4, $BillingTel1,
$BillingTel2, $BillingFax1, $BillingFax2, $BillingPostalCode, $BillingContact1,
$BillingContact2, $BillingEmail, $BillingHomePage, $IsActive, $Notes,
$CreateBy, $CreateDate, $EditBy, $EditDate, $Stamp, $AcCustomerNickName,
$DateOfBirth, $IsMember, $Gender, $MemberNo, $MobileNo, $IdentityNo,
$MemberJoinDate, $MemberExpireDate, $MemberMarriageDate, $AcMemberEthnicID,
$AcMemberIncomeID, $AcMemberOccupationID, $MemberPointBalance, $MemberPointAccumulated,
$PriceCode, $AcSalesmanID, $IsGSTRegister, $GSTRegisterNumber, $BusinessRegisterNumber,
$AcCurrencyID, $IsAllowPrintStatement, $IsAllowExceedCreditTerm, $IsAllowExceedCreditLimit,
$LocalCreditLimit, $LocalBalanceAmount, $AcTaxID, $IsAllowCreditSalesForPOS,
$MemberNotes, $AcINCardPackageID, $AcCustomerIDParentID, $TaxSLTRegistrationNo,
$TaxSVTRegistrationNo, $AcTaxIDSST, $SSTExemptionCertNumber;
// constructor with $db as database connection
public function __construct($db)
{
$this->conn = $db;
}
// read customers
function read()
{
// select all query
$query = "SELECT * FROM ".$this->table_name." ORDER BY AcCustomerName ASC";
// prepare query statement
$stmt = $this->conn->prepare($query, array(PDO::ATTR_CURSOR => PDO::CURSOR_SCROLL));
// execute query
$stmt->execute();
return $stmt;
}
// create product
function create()
{
// query to insert record
$query = "INSERT INTO
" . $this->table_name . "
(
AcCustomerID, AcCustomerName, AcTermID,
AcAreaID, AcCusGroupID, AcCusUDGroupID,
BillingEmail, IsActive, CreateBy,
CreateDate, Stamp, DateOfBirth,
IsMember, Gender, MobileNo,
MemberJoinDate, MemberExpireDate, MemberMarriageDate,
AcMemberEthnicID, AcMemberIncomeID, AcMemberOccupationID,
MemberPointBalance, MemberPointAccumulated, PriceCode,
AcSalesmanID, IsGSTRegister, AcCurrencyID,
IsAllowPrintStatement, IsAllowExceedCreditTerm, IsAllowExceedCreditLimit,
LocalCreditLimit, LocalBalanceAmount, IsAllowCreditSalesForPOS,
AcCustomerIDParentID
)
VALUES
(
:AcCustomerID, :AcCustomerName, :AcTermID,
:AcAreaID, :AcCusGroupID, :AcCusUDGroupID,
:BillingEmail, :IsActive, :CreateBy,
:CreateDate, :Stamp, :DateOfBirth,
:IsMember, :Gender, :MobileNo,
:MemberJoinDate, :MemberExpireDate, :MemberMarriageDate,
:AcMemberEthnicID, :AcMemberIncomeID, :AcMemberOccupationID,
:MemberPointBalance, :MemberPointAccumulated, :PriceCode,
:AcSalesmanID, :IsGSTRegister, :AcCurrencyID,
:IsAllowPrintStatement, :IsAllowExceedCreditTerm, :IsAllowExceedCreditLimit,
:LocalCreditLimit, :LocalBalanceAmount, :IsAllowCreditSalesForPOS,
:AcCustomerIDParentID
)";
// prepare query
$stmt = $this->conn->prepare($query);
// bind values
$stmt->bindParam(":AcCustomerID", $this->AcCustomerID);
$stmt->bindParam(":AcCustomerName", $this->AcCustomerName);
$stmt->bindParam(":AcTermID", $this->AcTermID);
$stmt->bindParam(":AcAreaID", $this->AcAreaID);
$stmt->bindParam(":AcCusGroupID", $this->AcCusGroupID);
$stmt->bindParam(":AcCusUDGroupID", $this->AcCusUDGroupID);
$stmt->bindParam(":BillingEmail", $this->BillingEmail);
$stmt->bindParam(":IsActive",$this->IsActive);
$stmt->bindParam(":CreateBy",$this->CreateBy);
$stmt->bindParam(":CreateDate",$this->CreateDate);
$stmt->bindParam(":Stamp",$this->Stamp);
$stmt->bindParam(":DateOfBirth",$this->DateOfBirth);
$stmt->bindParam(":IsMember",$this->IsMember);
$stmt->bindParam(":Gender",$this->Gender);
$stmt->bindParam(":MobileNo",$this->MobileNo);
$stmt->bindParam(":MemberJoinDate",$this->MemberJoinDate);
$stmt->bindParam(":MemberExpireDate",$this->MemberExpireDate);
$stmt->bindParam(":MemberMarriageDate",$this->MemberMarriageDate);
$stmt->bindParam(":AcMemberEthnicID",$this->AcMemberEthnicID);
$stmt->bindParam(":AcMemberIncomeID",$this->AcMemberIncomeID);
$stmt->bindParam(":AcMemberOccupationID",$this->AcMemberOccupationID);
$stmt->bindParam(":MemberPointBalance",$this->MemberPointBalance);
$stmt->bindParam(":MemberPointAccumulated",$this->MemberPointAccumulated);
$stmt->bindParam(":PriceCode",$this->PriceCode);
$stmt->bindParam(":AcSalesmanID",$this->AcSalesmanID);
$stmt->bindParam(":IsGSTRegister",$this->IsGSTRegister);
$stmt->bindParam(":AcCurrencyID",$this->AcCurrencyID);
$stmt->bindParam(":IsAllowPrintStatement",$this->IsAllowPrintStatement);
$stmt->bindParam(":IsAllowExceedCreditTerm",$this->IsAllowExceedCreditTerm);
$stmt->bindParam(":IsAllowExceedCreditLimit",$this->IsAllowExceedCreditLimit);
$stmt->bindParam(":LocalCreditLimit",$this->LocalCreditLimit);
$stmt->bindParam(":LocalBalanceAmount",$this->LocalBalanceAmount);
$stmt->bindParam(":IsAllowCreditSalesForPOS",$this->IsAllowCreditSalesForPOS);
$stmt->bindParam(":AcCustomerIDParentID",$this->AcCustomerIDParentID);
// execute query
if($stmt->execute())
{
return true;
}
return false;
}
}
?>
customer / create.php
<?php
// required headers
header("Access-Control-Allow-Origin: *");
header("Content-Type: application/json; charset=UTF-8");
header("Access-Control-Allow-Methods: POST");
header("Access-Control-Max-Age: 3600");
header("Access-Control-Allow-Headers: Content-Type, Access-Control-Allow-Headers, Authorization, X-Requested-With");
// get database connection
include_once '../config/database.php';
// instantiate product object
include_once '../objects/customer.php';
$database = new Database();
$db = $database->getConnection();
$db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$customer = new Customer($db);
// get posted data
$data = json_decode(file_get_contents("php://input"));
// make sure data is not empty
if(!empty($data->AcCustomerID)
&& !empty($data->AcCustomerName)
&& !empty($data->BillingEmail)
&& !empty($data->DateOfBirth)
&& !empty($data->MobileNo)
)
{
// set product property values
$customer->AcCustomerID = $data->AcCustomerID;
$customer->AcCustomerName = $data->AcCustomerName;
$customer->AcTermID = "CASH";
$customer->AcAreaID = "NA";
$customer->AcCusGroupID = "NA";
$customer->AcCusUDGroupID = "NA";
$customer->BillingEmail = $data->BillingEmail;
$customer->IsActive = "Y";
$customer->CreateBy = "APP";
$customer->CreateDate = date('Y-m-d H:i:s.u');
$customer->Stamp = "0";
$customer->DateOfBirth = date('Y-m-d H:i:s.u', strtotime($data->DateOfBirth));
$customer->IsMember = "Y";
$customer->Gender = "NA";
$customer->MobileNo = $data->MobileNo;
$customer->MemberJoinDate = date('Y-m-d H:i:s.u');
$customer->MemberExpireDate = date('Y-m-d H:i:s.u', strtotime('+1 year'));
$customer->MemberMarriageDate = date('Y-m-d H:i:s.u');
$customer->AcMemberEthnicID = "NA" ;
$customer->AcMemberIncomeID = "NA";
$customer->AcMemberOccupationID = "NA";
$customer->MemberPointBalance = "0.00";
$customer->MemberPointAccumulated = "0.0000";
$customer->PriceCode = "1";
$customer->AcSalesmanID = "NA";
$customer->IsGSTRegister = "N";
$customer->AcCurrencyID = "MYR";
$customer->IsAllowPrintStatement = "N";
$customer->IsAllowExceedCreditTerm = "N";
$customer->IsAllowExceedCreditLimit = "N";
$customer->LocalCreditLimit = "0.00";
$customer->LocalBalanceAmount = "0.00";
$customer->IsAllowCreditSalesForPOS = "N";
$customer->AcCustomerIDParentID = $data->AcCustomerID;
// create the product
/*if($customer->create())
{
// set response code - 201 created
http_response_code(201);
// tell the user
//echo json_encode(array("message" => "New Member was created."));
}
// if unable to create the product, tell the user
else
{
// set response code - 503 service unavailable
http_response_code(503);
// tell the user
echo json_encode(array("message" => "Unable to create new member."));
}*/
try
{
if($customer->create())
{
// set response code - 201 created
http_response_code(201);
// tell the user
echo json_encode(array("message" => "New Member was created."));
}
}
catch (PDOException $e)
{
echo json_encode(array("message" => $e->getMessage()));
}
}
// tell the user data is incomplete
else
{
// set response code - 400 bad request
http_response_code(400);
// tell the user
echo json_encode(array("message" => "Unable to create new member. Data is incomplete."));
}
?>
输出
1个回答
0
投票
投票
有2个问题
您的日期时间格式不正确，应为
date('Y-m-d H:i:s.u');，应为date('Y-m-d H:i:s');当表将Gender设置为nvarchar（1）时，Gender设置为'NA'（2个字符），仅表示一个字符。将性别更改为一个字符或增加nvarchar限制。
最新问题
- WPF ComboBox 获取突出显示的项目
- 修改 Windows 2016 EC2 Windows 实例上的右上角信息面板
- ASP.NET 端 Datagrid 中数据的动态过滤器
- Azure DevOps 自定义管道任务更新到新版本通过了验证，但实际上失败了，没有任何错误并且未使用更新版本
- 如何断言 cypress 中每页有 10 个项目的 50 页上的项目总数？
- QGraphicsView 使用鼠标滚轮在鼠标位置下放大和缩小
- window.print() 打印空白页
- 无法在 Intellij 下运行 Junit 测试，但可以在 Intellij IDE 中的 maven 下运行
- Rundeck 通过 api 触发作业，无需暴露脚本
- 使用 Azure 用户身份验证的 Node js 应用程序中具有 DefaultAzureCredentials 的应用程序见解
- Pytest：仅运行 linter 检查（pytest-flake8），不运行测试
- Inertiajs onFinish 在 redux 工具包减速器中不起作用
- 更新一个表的列中的值（如果这些值存在于另一个表的列中并且这些值是唯一的）
- Runtime.getRuntime().gc()有副作用吗[重复]
- Blazor：名称“Acti”在当前上下文中不存在
- 有没有一种方法可以使用带有默认字段和__slots__的数据类
- 如何让我的程序休眠 50 毫秒？
- 如何检查 Selenium Python WebDriver 中的复选框是否已选中？
- 整理一大张纸
- 将切换复选框的值发送到 ASP.NET MVC 中的控件
© www.soinside.com 2019 - 2024. All rights reserved.