• [PHP]关联和操作MySQL数据库然后将数据库部署到ECS

    在Mac电脑上使用VS Code进行PHP开发并关联操作MySQL数据库，然后将数据库部署到ECS。

    1.安装PHP和MySQL

    确保你的Mac上已经安装了PHP和MySQL。你可以使用Homebrew来安装它们：

    1. $ brew install php 
    2. $ brew install mysql

    安装mysql完成后记住这一句:

    1. MySQL is configured to only allow connections from localhost by default
    2.  
    3. To connect run:
    4.     mysql -u root

    使用以下命令查询安装情况：

    1. $ php -v
    2. $ mysql --version

    启动MySQL服务：

    $ brew services start mysql

    重启MySQL服务：

    $ brew services restart mysql

    停止MySQL服务：

    $ brew services stop mysql

    2.创建MySQL用户、数据库和权限

    登录到MySQL：

    1. // 无密码直接用这一句登录
    2. $ mysql -u root
    3. // 也可以用这指令，输密码是直接回车跳过就是
    4. $ mysql -u root -p

    创建新数据库：

    $ CREATE DATABASE mydatabase;

    创建新用户并设置密码（替换myuser和mypassword为你自己的设置）：

    $ CREATE USER'myuser'@'localhost' IDENTIFIED BY'mypassword';

    授权新用户访问数据库：

    $ GRANT ALL PRIVILEGES ON mydatabase.*TO'myuser'@'localhost';

    刷新权限：

    $ FLUSH PRIVILEGES;

    退出MySQL：

    $ EXIT;

    3.配置PHP连接MySQL

    你需要在PHP代码中使用PDO或mysqli扩展来连接MySQL数据库。

    确保你的MySQL服务正在运行，并且你已经创建了相应的用户、数据库和权限。

    1).PDO

    2. $host = '127.0.0.1';
    3. $db   = 'your_database';
    4. $user = 'your_username';
    5. $pass = 'your_password';
    6. $charset = 'utf8mb4';
    7.  
    8. $dsn = "mysql:host=$host;dbname=$db;charset=$charset";
    9. $options = [
    10.     PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION,
    11.     PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
    12.     PDO::ATTR_EMULATE_PREPARES   => false,
    13. ];
    14.  
    15. try {
    16.     $pdo = new PDO($dsn, $user, $pass, $options);
    17. } catch (\PDOException $e) {
    18.     throw new \PDOException($e->getMessage(), (int)$e->getCode());
    19. }
    20. ?>

    2).mysqli扩展

    2.  
    3. // 数据库连接配置
    4. $host = 'localhost';
    5. $dbname = 'mydatabase';
    6. $username = 'myusername';
    7. $password = 'mypassword';
    8.  
    9. // 创建 mysqli 连接对象
    10. $conn = new mysqli($host, $username, $password, $dbname);
    11.  
    12. // 检查连接是否成功
    13. if ($conn->connect_error) {
    14.     die("连接失败: " . $conn->connect_error);
    15. }
    16.  
    17. // 执行查询语句
    18. $query = "SELECT * FROM users";
    19. $result = $conn->query($query);
    20.  
    21. // 处理结果集
    22. if ($result->num_rows > 0) {
    23.     while ($row = $result->fetch_assoc()) {
    24.         echo $row['username'] . "
      "      ;
    25.     }
    26. } else {
    27.     echo "没有结果";
    28. }
    29.  
    30. // 关闭数据库连接
    31. $conn->close();
    32.  
    33. ?>

    4.在VS Code中编写和运行PHP代码

    注意：使用Launch Built-in web server配置运行时，需要将"localhost:0"改成其它端口，不然每次运行都会随机生成端口号，很不方便。

    Demo：https://github.com/Gamin-fzym/php_test_demo

    index.html

    城市信息表单

    1. html>
    2. <html>
    3. <head>
    4.     <title>城市信息表单title>
    5. head>
    6. <body>
    7.     <h1>城市信息表单h1>
    8.     <form action="http://localhost:8080/city.php" method="post">
    9.         <label for="cityName">城市名称:label>
    10.         <input type="text" id="name" name="name" required><br><br>
    11.  
    12.         <label for="cityCode">城市编码:label>
    13.         <input type="text" id="code" name="code" required><br><br>
    14.  
    15.         <label for="cityCode">增删改查:label>
    16.         <input type="text" id="mark" name="mark" required><br><br>
    17.  
    18.         <input type="submit" value="提交">
    19.     form>
    20.  
    21.     <p id="jsonResponse">p>
    22.  
    23.     <script>
    24.         document.querySelector('form').addEventListener('submit', function (event) {
    25.             event.preventDefault();
    26.             // 方式一：PHP 中使用这种方式获取 $name = $_POST['name'] ?? '';
    27.             var form = event.target;
    28.             var formData = new FormData(form);
    29.             fetch(form.action, {
    30.                 method: 'POST',
    31.                 body: formData
    32.             })
    33.             .then(response => response.json())
    34.             .then(data => {
    35.                 document.getElementById('jsonResponse').textContent = JSON.stringify(data);
    36.             })
    37.             .catch(error => console.error('请求接口失败', error));
    38.  
    39.             /*
    40.             // 方式二：PHP中用这种方式获取 $data = json_decode(file_get_contents('php://input'), true);  $name = $data['name'] ?? '';
    41.             var form = event.target;
    42.             var name = form.elements.name.value;
    43.             var code = form.elements.code.value;
    44.             var mark = form.elements.mark.value;
    45.             var requestData = {
    46.                 name: name,
    47.                 code: code,
    48.                 mark: parseInt(mark) // mark 1:增 2:删 3:改 4:查
    49.             };
    51.             var xhr = new XMLHttpRequest();
    52.             xhr.open('POST', form.action);
    53.             xhr.setRequestHeader('Content-Type', 'application/json');
    54.             // xhr.setRequestHeader('Content-Type', 'application/x-www-form-urlencoded');
    55.             xhr.onload = function () {
    56.                 if (xhr.status === 200) {
    57.                     var data = JSON.parse(xhr.responseText);
    58.                     document.getElementById('jsonResponse').textContent = JSON.stringify(data);
    59.                 } else {
    60.                     console.error('请求接口失败');
    61.                 }
    62.             };
    63.             xhr.send(JSON.stringify(requestData));
    64.             */
    65.         });
    66.     script>
    67. body>
    68. html>

    pdoConnect.php

    PDO连接MySQL封装

    2. $host = '127.0.0.1';
    3. $db = 'city_database';
    4. $user = 'gamin';
    5. $pass = '123456';
    6. $charset = 'utf8mb4';
    7.  
    8. $dsn = "mysql:host=$host;dbname=$db;charset=$charset";
    9. $options = [
    10.     PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION,
    11.     PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
    12.     PDO::ATTR_EMULATE_PREPARES   => false,
    13. ];
    14.  
    15. // 连接数据库
    16. try {
    17.     $pdo = new PDO($dsn, $user, $pass, $options);
    18.     createCitiesTable();
    19. } catch (\PDOException $e) {
    20.     throw new \PDOException($e->getMessage(), (int)$e->getCode());
    21. }
    22.  
    23. // 创建城市表
    24. function createCitiesTable() {
    25.     $tb_name = "cities";
    26.     // 检查表是否已存在
    27.     $isTableExists = checkTableExists($tb_name);
    28.     if (!$isTableExists) { 
    29.         // 创建表
    30.         $sql = "CREATE TABLE $tb_name (
    31.             id INT AUTO_INCREMENT PRIMARY KEY,
    32.             name VARCHAR(255) NOT NULL,
    33.             code INT NOT NULL
    34.         )";
    35.         global $pdo;
    36.         $pdo->exec($sql);
    37.     } else {
    38.          
    39.     }
    40. }
    41.  
    42. // 检查表是否存在
    43. function checkTableExists($tableName) {
    44.     global $pdo;
    45.     $stmt = $pdo->query("SHOW TABLES LIKE '$tableName'");
    46.     return $stmt->rowCount() > 0;
    47. }
    48.  
    49. ?>

    sqlOperation.php

    操作封装

    2. require "pdoConnect.php";
    3.  
    4. function pdo() {
    5.     global $pdo;
    6.     if (isset($pdo)) {
    7.         return $pdo;
    8.     } else {
    9.         // 处理 $pdo 未初始化的情况
    10.         return null;
    11.     }
    12. }
    13.  
    14. // 改变数据 插入|更新|删除
    15. function changeData(string $sql, array $arr) {
    16.     $stmt = pdo()?->prepare($sql);
    17.     $result = $stmt?->execute($arr);
    18.     return $result;
    19. }
    20.  
    21. // 查询数据
    22. function findData(string $sql, array $arr) {
    23.     $stmt = pdo()?->prepare($sql);
    24.     $stmt?->execute($arr);
    25.     $result = $stmt?->fetch();
    26.     return $result;
    27. }
    28.  
    29. ?>

    output.php

    输出封装

    2.  
    3. class ErrorCode {
    4.     const FAILURE = -1;
    5.     const SUCCESS = 0;
    6.     const INVALID_INPUT = 100;
    7.     const MISSING_PARAMETER = 101;
    8.     const DATABASE_ERROR = 200;
    9.     const FILE_NOT_FOUND = 201;
    10.     const METHOD_NOT_ALLOW = 405;
    11.     const INTERNAL_SERVER_ERROR = 500;
    12.     const DATA_NOT_FOUND = 1000;
    13.  
    14.     public static function getErrorMessage($errorCode) {
    15.         switch ($errorCode) {
    16.             case self::FAILURE:
    17.                 return "Operation failed.";
    18.             case self::SUCCESS:
    19.                 return "Operation succeeded.";
    20.             case self::INVALID_INPUT:
    21.                 return "Invalid input provided.";
    22.             case self::MISSING_PARAMETER:
    23.                 return "Required parameter is missing.";
    24.             case self::DATABASE_ERROR:
    25.                 return "Database error occurred.";
    26.             case self::FILE_NOT_FOUND:
    27.                 return "File not found.";
    28.             case self::METHOD_NOT_ALLOW:
    29.                 return "Method not allowed.";   
    30.             case self::INTERNAL_SERVER_ERROR:
    31.                 return "Internal Server Error.";   
    32.             case self::DATA_NOT_FOUND:
    33.                 return "No matching data found.";  
    34.             default:
    35.                 return "Unknown error occurred.";
    36.         }
    37.     }
    38. }
    39.  
    40. function outputJSON(int $errorCode, $data = []) {
    41.     // 构建要返回的数据
    42.     $response = [
    43.         'code' => $errorCode,
    44.         'message' => ErrorCode::getErrorMessage($errorCode),
    45.         'data' => $data
    46.      ];
    47.     
    48.     // 设置响应内容为 JSON 格式
    49.     header('Content-Type: application/json');
    50.  
    51.     // 将数据转换为 JSON 字符串
    52.     $json = json_encode($response);
    53.  
    54.     // 输出 JSON 字符串
    55.     echo $json;
    56. }
    57.  
    58. ?>

    city.php

    增加、删除、修改、查询城市

    2. require "sqlOperation.php";
    3. require "output.php";
    4.  
    5. $tb_name = "cities";
    6.  
    7. // 检查POST数据
    8. if ($_SERVER['REQUEST_METHOD'] === 'POST') {
    9.     /* 方式一： */
    10.     // 获取数据并验证
    11.     $name = $_POST['name'] ?? '';
    12.     $code = $_POST['code'] ?? '';
    13.     $mark = $_POST['mark'] ?? 0;
    14.  
    15.     /* 方式二：表单中Content-Type用'application/json'时，用这种方式获取传参 
    16.     // 获取 JSON 数据并解析
    17.     $data = json_decode(file_get_contents('php://input'), true);
    18.     // 获取数据并验证
    19.     $name = $data['name'] ?? '';
    20.     $code = $data['code'] ?? '';
    21.     $mark = $data['mark'] ?? 0;
    22.     */
    23.  
    24.     if (empty($name) || empty($code) || $mark == 0) {
    25.         outputJSON(ErrorCode::MISSING_PARAMETER);
    26.         return;
    27.     }
    28.  
    29.     // mark 1:增 2:删 3:改 4:查
    30.     if ($mark == 1) {
    31.         // 插入数据
    32.         $result = changeData("INSERT INTO $tb_name (name, code) VALUES (:name, :code)", ['name' => $name, 'code' => $code]);
    33.         if ($result) {
    34.             outputJSON(errorCode::SUCCESS);
    35.         } else {
    36.             outputJSON(errorCode::FAILURE);
    37.         }
    38.     } else if ($mark == 2) {
    39.         // 删除数据
    40.         $result = changeData("DELETE FROM $tb_name WHERE code = :code", ['code' => $code]);
    41.         if ($result) {
    42.             outputJSON(errorCode::SUCCESS);
    43.         } else {
    44.             outputJSON(errorCode::FAILURE);
    45.         }
    46.     } else if ($mark == 3) {
    47.         // 更新数据
    48.         $result = changeData("UPDATE $tb_name SET name = :name WHERE code = :code", ['name' => $name, 'code' => $code]);
    49.         if ($result) {
    50.             outputJSON(errorCode::SUCCESS);
    51.         } else {
    52.             outputJSON(errorCode::FAILURE);
    53.         }
    54.     } else if ($mark == 4) {
    55.         // 查询数据
    56.         $result = findData("SELECT * FROM $tb_name WHERE code = :code", ['code' => $code]);
    57.         if ($result) {
    58.             // 查询成功，至少有一条匹配的数据
    59.             outputJSON(errorCode::SUCCESS,$result);
    60.         } else {
    61.             // 查询失败，没有匹配的数据
    62.             outputJSON(ErrorCode::DATA_NOT_FOUND);
    63.         }
    64.     }
    65.  
    66.     exit;
    67. }
    68.  
    69. ?>

    cityList.php

    分页查询城市列表

    2. require("pdoConnect.php");
    3. require("output.php");
    4.  
    5. // 检查POST数据
    6. if ($_SERVER['REQUEST_METHOD'] === 'POST') { 
    7.     try {
    8.         // 获取数据并验证
    9.         $page = isset($_POST['page']) ? intval($_POST['page']) : 1; // 当前页码，默认为第一页
    10.         $pageSize = isset($_POST['pageSize']) ? intval($_POST['pageSize']) : 10; // 每页数据条数，默认为 10
    11.  
    12.         // 对页码进行有效性检查
    13.         $page = max(1, intval($page)); ;
    14.         // 确保每页记录数为正整数
    15.         $pageSize = max(1, intval($pageSize)); ;
    16.  
    17.         // 表名
    18.         $tb_name = "cities";
    19.  
    20.         // 查询总记录数
    21.         $countSql = "SELECT COUNT(*) AS total FROM $tb_name";
    22.         $countStmt = $pdo->prepare($countSql);
    23.         $countStmt->execute();
    24.         $totalItems = $countStmt->fetchColumn();
    25.         // 计算总页数
    26.         $totalPages = ceil($totalItems / $pageSize);
    27.  
    28.         // 对页码进行有效性检查
    29.         $page = min($page, $totalPages);
    30.         // 计算偏移量
    31.         $offset = ($page - 1) * $pageSize;
    32.  
    33.         // 查询当前页的数据
    34.         $sql = "SELECT * FROM $tb_name LIMIT :offset, :pageSize";
    35.         $stmt = $pdo->prepare($sql);
    36.         $stmt->bindValue(':offset', $offset, PDO::PARAM_INT);
    37.         $stmt->bindValue(':pageSize', $pageSize, PDO::PARAM_INT);
    38.         $stmt->execute();
    39.  
    40.         $pagedData = $stmt->fetchAll(PDO::FETCH_ASSOC);
    41.  
    42.         // 构建要返回的数据
    43.         $response = [
    44.             'page' => $page,
    45.             'pageSize' => $pageSize,
    46.             'totalPages' => $totalPages,
    47.             'totalItems' => $totalItems,
    48.             'data' => array_map(function ($item) {
    49.                 return $item;
    50.             }, $pagedData)
    51.         ];
    52.         outputJSON(ErrorCode::SUCCESS, $response);
    53.     } catch (Exception $e) {
    54.         // 发生错误时返回错误响应
    55.         outputJSON(ErrorCode::INTERNAL_SERVER_ERROR);
    56.     }
    57. } else {
    58.     // 非 POST 请求返回错误响应
    59.     outputJSON(ErrorCode::METHOD_NOT_ALLOW);
    60. }
    61.  
    62. ?>

    5.测试本地开发环境

    在本地开发环境中测试你的PHP脚本，确保它可以正确地与MySQL数据库进行交互。

    6.将MySQL数据库部署到ECS

    1).创建ECS实例：登录到阿里云管理控制台，创建一个ECS实例。

    2).安装MySQL：通过SSH连接到你的ECS实例，使用相应的包管理器安装MySQL。

    3).配置MySQL：设置用户权限、创建数据库，并导入你的本地数据库数据到ECS上的MySQL实例。

    4).更新你的PHP代码中的数据库连接信息，使其指向ECS实例上的MySQL。

    7.部署PHP代码到ECS

    1).将你的PHP代码上传到ECS实例。你可以使用FTP、SCP或者Git来传输文件。

    2).配置Web服务器：在ECS上安装和配置Nginx或Apache作为Web服务器来处理PHP请求。

    3).确保ECS的安全组规则允许访问MySQL和Web服务器的端口。

    8.测试远程环境

    在浏览器中访问你的ECS实例的公网IP地址，确保你的PHP应用能够正确地运行并连接到MySQL数据库。

  • 相关阅读:
    typescript高级类型-类型兼容性
    mysql主从复制和读写分离
    java计算机毕业设计校园爱心公益平台设计与实现源码+系统+mysql数据库+lw文档+部署
    心脏出血漏洞复现（CVE-2014-0160）
    动态权重之多任务不平衡论文 (一)
    数据仓库和数据湖的区别
    列表页面新增 字段查询 ，点击查询后，前端页面和后端控制台 出现红色报错信息，查询数据失败。
    IO流 -- 调研
    Vue iconfont-阿里巴巴矢量图标库用法
    rocketmq
  • 原文地址：https://blog.csdn.net/u012881779/article/details/134472774