如何在 PostgreSQL 中使用 row_to_json 分配 JSON 变量

How to assign a JSON variable with row_to_json in PostgreSQL

我正在尝试在 PostgreSQL 中创建一个匿名函数来为应用程序创建模拟数据。我想先做一个 SELECT 查询(从随机获取数据charter) 并将所有行转换为 JSON 和 row_to_json,然后将结果分配给类型为 JSON 的变量。

我需要此包机信息,以便将其添加到预订中 table。

这不起作用,我想我不知道如何将 select 的结果与先前创建的变量相关联;我收到 charterData 为 null 的错误,我想知道如何实现这一点..

这是SQL中的匿名函数:

BEGIN;
    DO $$
    DECLARE charterData JSON;
    DECLARE bookingId INTEGER;
    BEGIN
        SELECT row_to_json(t) INTO charterData FROM (select charter_id, name from charters) t WHERE charter_id = 1;
        INSERT INTO bookings (charter, yacht, email, date, guests, total, start_hour, end_hour, hotel, arrival_date) values (charterData, '{"test":1}', 'a', '12/10/1995', 8, '78', '123', '123', '123', '123')
        RETURNING booking_id INTO bookingId;
    END $$;
COMMIT;

Table包机:

                                        Table "public.charters"
   Column    |       Type        | Collation | Nullable |                   Default                    
-------------+-------------------+-----------+----------+----------------------------------------------
 charter_id  | integer           |           | not null | nextval('charters_charter_id_seq'::regclass)
 name        | character varying |           | not null | 
 description | character varying |           | not null | 
 sail_hours  | integer           |           | not null | 
Indexes:
    "charters_pk" PRIMARY KEY, btree (charter_id)
    "name_charter" UNIQUE CONSTRAINT, btree (name)
Referenced by:
    TABLE "bookings" CONSTRAINT "charters_bookings_fk" FOREIGN KEY (charter) REFERENCES charters(name) ON DELETE CASCADE
    TABLE "pricing" CONSTRAINT "charters_pricing_fk" FOREIGN KEY (charter_id) REFERENCES charters(charter_id) ON DELETE CASCADE

预订table:

                                         Table "public.bookings"
     Column     |       Type        | Collation | Nullable |                   Default                    
----------------+-------------------+-----------+----------+----------------------------------------------
 booking_id     | integer           |           | not null | nextval('bookings_booking_id_seq'::regclass)
 charter        | json              |           | not null | 
 yacht          | json              |           | not null | 
 email          | character varying |           | not null | 
 date           | date              |           | not null | 
 guests         | integer           |           | not null | 
 total          | numeric           |           | not null | 
 start_hour     | character varying |           | not null | 
 end_hour       | character varying |           | not null | 
 alcohol        | character varying |           |          | 
 transportation | character varying |           |          | 
 others         | character varying |           |          | 
 arrival_date   | character varying |           |          | 
 hotel          | character varying |           |          | 
Indexes:
    "bookings_pk" PRIMARY KEY, btree (booking_id)
    "end_hour" UNIQUE CONSTRAINT, btree (end_hour)
    "start_hour" UNIQUE CONSTRAINT, btree (start_hour)
Foreign-key constraints:
    "charters_bookings_fk" FOREIGN KEY (charter) REFERENCES charters(name) ON DELETE CASCADE
    "yachts_bookings_fk" FOREIGN KEY (yacht) REFERENCES yachts(name) ON DELETE CASCADE
Referenced by:
    TABLE "bookings_extra" CONSTRAINT "bookings_extra_fk" FOREIGN KEY (booking_id) REFERENCES bookings(booking_id) ON DELETE CASCADE

好的,我找到了答案...有点傻,但也许这个答案会对某人有所帮助

BEGIN;
    DO $$
    DECLARE charter JSON;
    DECLARE bookingId INTEGER;
    BEGIN
        charter := (SELECT row_to_json(t) FROM (SELECT charter_id, name FROM charters) t WHERE charter_id = );
        INSERT INTO bookings
            (charter, yacht, email, date, passengers, total, start_hour, end_hour, hotel, arrival_date, charter_price)
        values (charter, '{"test":1}', 'a', '12/10/1995', 8, '78', '123', '123', '123', '123', '132')
            RETURNING booking_id INTO bookingId;
    END $$;
COMMIT;