PHP JSON

Slim中的PHPJSON

在下面的示例中，我们从Slim应用程序返回JSON数据。

$ composer req slim/slim
$ composer req slim/psr7
$ composer req slim/http

我们安装了slim/slim、slim/psr7和slim/http包。

<?php

use Psr\Http\Message\ResponseInterface as Response;
use Psr\Http\Message\ServerRequestInterface as Request;
use Slim\Factory\AppFactory;

require __DIR__ . '/../vendor/autoload.php';

$app = AppFactory::create();

$app->get('/city', function (Request $request, Response $response): Response {

    $cities = [
        ["id" => 1, "name" => "Bratislava", "population" => 432000],
        ["id" => 2, "name" => "Budapest", "population" => 1759000],
        ["id" => 3, "name" => "Prague", "population" => 1280000],
        ["id" => 4, "name" => "Warsaw", "population" => 1748000],
        ["id" => 5, "name" => "Los Angeles", "population" => 3971000],
        ["id" => 6, "name" => "New York", "population" => 8550000],
        ["id" => 7, "name" => "Edinburgh", "population" => 464000],
        ["id" => 8, "name" => "Berlin", "population" => 3671000],
    ];

    return $response->withJson(["cities" => $cities]);
});

$app->run();

我们使用Response的withJson方法返回JSON数据。

Symfony中的PHPJSON

在下面的示例中，我们从Symfony应用程序发送一个JSON响应。

$ symfony new symjson
$ cd symjson

创建了一个新的应用程序。

$ composer req annot
$ composer req symfony/orm-pack
$ composer req symfony/console

我们安装了annot、symfony/orm-pack和symfony/console组件。

...
DATABASE_URL=sqlite:///%kernel.project_dir%/var/ydb.db
...

我们为SQLite数据库设置了一个数据库URL。

$ php bin/console doctrine:database:create

我们创建数据库。

<?php

namespace App\Command;

use Doctrine\DBAL\Driver\Connection;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;


class CreateCityTable extends Command
{
    private $conn;

    public function __construct(Connection $conn)
    {
        $this->conn = $conn;

        parent::__construct();
    }

    protected function configure()
    {
        $this->setName('app:create-table')
            ->setDescription('Creates City table')
            ->setHelp('This command creates a City table');
    }

    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        $q1 = "CREATE TABLE cities(id INTEGER PRIMARY KEY, name TEXT, population INTEGER)";
        $this->conn->executeQuery($q1);

        $q2 = "INSERT INTO cities(name, population) VALUES('Bratislava', 432000)";
        $this->conn->executeQuery($q2);

        $q3 = "INSERT INTO cities(name, population) VALUES('Budapest', 1759000)";
        $this->conn->executeQuery($q3);

        $q4 = "INSERT INTO cities(name, population) VALUES('Prague', 1280000)";
        $this->conn->executeQuery($q4);

        $q5 = "INSERT INTO cities(name, population) VALUES('Warsaw', 1748000)";
        $this->conn->executeQuery($q5);

        $q6 = "INSERT INTO cities(name, population) VALUES('Los Angeles', 3971000)";
        $this->conn->executeQuery($q6);

        $q7 = "INSERT INTO cities(name, population) VALUES('New York', 8550000)";
        $this->conn->executeQuery($q7);

        $q8 = "INSERT INTO cities(name, population) VALUES('Edinburgh', 464000)";
        $this->conn->executeQuery($q8);

        $q9 = "INSERT INTO cities(name, population) VALUES('Berlin', 3671000)";
        $this->conn->executeQuery($q9);

        $output->writeln('table successfully created');

        return Command::SUCCESS;
    }
}

这是在数据库中创建cities表的命令。

$ php bin/console app:create-table

命令被执行。

<?php

namespace App\Repository;

use Doctrine\DBAL\Driver\Connection;

class CityRepository
{
    protected $conn;

    public function __construct(Connection $conn)
    {
        $this->conn = $conn;
    }

    public function all(): array
    {
        $queryBuilder = $this->conn->createQueryBuilder();
        $queryBuilder->select('*')->from('cities');
        $stm = $queryBuilder->execute();

        return $stm->fetchAll();
    }
}

在CityRepository中，我们有all方法来检索所有行。我们使用DoctrineDBAL来执行数据库查询。

<?php

namespace App\Controller;

use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Component\HttpFoundation\JsonResponse;
use Symfony\Component\Routing\Annotation\Route;
use App\Repository\CityRepository;

class CityController extends AbstractController
{
    /**
     * @Route("/city", name="city")
     * @param CityRepository $cityRepository
     * @return JsonResponse
     */
    public function index(CityRepository $cityRepository): JsonResponse
    {
        $cities = $cityRepository->all();

        return $this->json([
            'cities' => $cities
        ]);
    }
}

在控制器内部，我们使用CityRepository获取所有数据。使用json助手将数据转换为JSON。

$ symfony serve

我们启动Web服务器并定位到localhost:8000/city。

Laravel中的PHPJSON

在下面的示例中，我们从Laravel应用程序发送JSON响应。

$ laravel new larajson
$ cd larajson

我们创建一个新的Laravel应用程序。

...
DB_CONNECTION=sqlite
DB_DATABASE=/tmp/ydb.db
...

我们定义连接和数据库文件。

$ touch /tmp/ydb.db

我们创建数据库文件。

$ php artisan make:migration create_cities_table
Created Migration: 2020_07_25_101535_create_cities_table

cities表的新迁移已创建。

<?php

use Illuminate\Database\Migrations\Migration;
use Illuminate\Database\Schema\Blueprint;
use Illuminate\Support\Facades\Schema;

class CreateCitiesTable extends Migration
{
    /**
     * Run the migrations.
     *
     * @return void
     */
    public function up()
    {
        Schema::create('cities', function (Blueprint $table) {
            $table->id();
            $table->string('name');
            $table->integer('population');
        });
    }

    /**
     * Reverse the migrations.
     *
     * @return void
     */
    public function down()
    {
        Schema::dropIfExists('cities');
    }
}

在迁移文件中，我们为cities表创建了一个模式。

$ php artisan migrate

我们运行迁移。

$ php artisan make:seeder CitySeeder

我们为我们的数据库创建了一个数据播种器。

<?php

use Illuminate\Database\Seeder;

class CitySeeder extends Seeder
{
    /**
     * Run the database seeds.
     *
     * @return void
     */
    public function run()
    {
        DB::table('cities')->insert([
            ['name' => 'Bratislava', 'population' => 432000],
            ["name" => "Budapest", "population" => 1759000],
            ["name" => "Prague", "population" => 1280000],
            ["name" => "Warsaw", "population" => 1748000],
            ["name" => "Los Angeles", "population" => 3971000],
            ["name" => "New York", "population" => 8550000],
            ["name" => "Edinburgh", "population" => 464000],
            ["name" => "Berlin", "population" => 3671000]
        ]);
    }
}

播种器向表中插入八行。

$ php artisan db:seed --class=CitySeeder

我们执行播种机。

<?php

use Illuminate\Support\Facades\Route;
use Illuminate\Http\JsonResponse;

Route::get('/city', function (): JsonResponse {

    $cities = DB::table('cities')->get();

    return response()->json([
        'cities' => $cities
    ]);
});

在路由中，我们从数据库中选择所有数据，并使用json助手将其作为JSON返回。

$ php artisan serve

我们运行网络服务器。

$ curl localhost:8000/city
{"cities":[{"id":"1","name":"Bratislava","population":"432000"},
{"id":"2","name":"Budapest","population":"1759000"},
{"id":"3","name":"Prague","population":"1280000"},
{"id":"4","name":"Warsaw","population":"1748000"},
{"id":"5","name":"Los Angeles","population":"3971000"},
{"id":"6","name":"New York","population":"8550000"},
{"id":"7","name":"Edinburgh","population":"464000"},
{"id":"8","name":"Berlin","population":"3671000"}]}

我们使用curl工具获取数据。

来自客户端的PHPJSON

Symfony提供了HttpClient组件，它使我们能够在PHP中创建HTTP请求。我们还可以发送JSON数据。

$ composer req symfony/http-client

我们安装了symfony/http-client组件。

<?php

require('vendor/autoload.php');

use Symfony\Component\HttpClient\HttpClient;

$httpClient = HttpClient::create();
$response = $httpClient->request('GET', 'http://localhost:8000/greet',  [
    'json' => [
        'name' => 'Lucia',
        'message' => 'Cau'
    ]
]);

$content = $response->getContent();
echo $content . "\n";

该示例发送带有JSON负载的GET请求。

<?php

namespace App\Controller;

use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Component\Routing\Annotation\Route;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\HttpFoundation\Request;

class GreetController extends AbstractController
{
    /**
     * @Route("/greet", name="greet")
     */
    public function index(Request $request): Response
    {
        $params = [];
        if ($data = $request->getContent()) {
            $params = json_decode($data, true);
        }

        $msg = "{$params['name']} says {$params['message']}";

        $textResponse = new Response($msg , 200);
        $textResponse->headers->set('Content-Type', 'text/plain');

        return $textResponse;
    }
}

在GreetController中，我们处理JSON数据并生成一条文本消息，返回给客户端。

$ php send_json_req.php 
Lucia says Cau

这是输出。

在本教程中，我们在纯PHP、Symfony、Slim和Laravel中处理了JSON数据。

列出所有PHP教程。