2017-05-16 112 views
0

我想为一些gtfs-feed数据添加一个非规范化表。为此,我创建了一个新表格:Postgresql错误地插入值

CREATE TABLE denormalized_trips (
    stops_coords json NOT NULL, 
    stops_object json NOT NULL, 
    agency_key text NOT NULL, 
    trip_id text NOT NULL, 
    route_id text NOT NULL, 
    service_id text NOT NULL, 
    shape_id text, 
    route_color text, 
    route_long_name text, 
    route_desc text, 
    direction_id text 
); 

CREATE INDEX denormalized_trips_index ON denormalized_trips (agency_key, trip_id); 
CREATE UNIQUE INDEX denormalized_trips_index ON denormalized_trips (agency_key, route_id); 

现在我想通过insert语句将数据从一个表传输到另一个表。声明相当复杂。

INSERT INTO denormalized_trips 
SELECT 
    trps.stops_coords, 
    trps.stops_object, 
    trps.trip_id, 
    trps.service_id, 
    trps.route_id, 
    trps.direction_id, 
    trps.agency_key, 
    trps.shape_id, 
    trps.route_color, 
    trps.route_long_name, 
    trps.route_desc 
FROM (
SELECT 
    array_to_json(ARRAY_AGG(array[stop_lat, stop_lon])) AS stops_coords, 
    array_to_json(ARRAY_AGG(array[ 
      stops.stop_id, 
      CAST (stop_times.stop_sequence AS TEXT), 
      stops.stop_name, 
      stop_times.departure_time, 
      CAST (stop_times.departure_time_seconds AS TEXT), 
      stop_times.arrival_time, 
      CAST (stop_times.arrival_time_seconds AS TEXT) 
     ])) AS stops_object, 
    trips.trip_id, 
    trips.service_id, 
    trips.direction_id, 
    trips.agency_key, 
    trips.shape_id, 
    routes.route_id, 
    routes.route_color, 
    routes.route_long_name, 
    routes.route_desc 
FROM gtfs_stop_times AS stop_times 

INNER JOIN gtfs_trips AS trips 
    ON trips.trip_id = stop_times.trip_id AND trips.agency_key = stop_times.agency_key 

INNER JOIN gtfs_routes AS routes ON trips.agency_key = routes.agency_key AND routes.route_id = trips.route_id 

INNER JOIN gtfs_stops AS stops 
    ON stops.stop_id = stop_times.stop_id 
    AND stops.agency_key = stop_times.agency_key 
    AND NOT EXISTS (
     SELECT 0 
     FROM denormalized_max_stop_sequence AS max 
     WHERE max.agency_key = stop_times.agency_key 
     AND max.trip_id = stop_times.trip_id 
     AND max.trip_max = stop_times.stop_sequence 
    ) 
GROUP BY 
    trips.trip_id, 
    trips.service_id, 
    trips.direction_id, 
    trips.agency_key, 
    trips.shape_id, 
    routes.route_id, 
    routes.route_color, 
    routes.route_long_name, 
    routes.route_desc 
) as trps 

如果我只是运行内部select语句,我会得到正确的结果。他们看起来是这样的:(截图没有显示所有的表,因为它太长)

Correct results

但如果我执行INSERT语句,并显示表的内容,我会得到这样的: Wrong results

正如您可能注意到内容未插入到表格的右列中。 agency_key现在具有trip_id的值,并且direction_id现在是service_id(并且有更多的表被混淆)。

所以我的问题是我做错了,我的插入语句插入内容到新创建表的错误列?

感谢您的帮助。

回答

3

默认情况下,Postgres将按列中声明的顺序插入值;它与你的列在查询中被命名无关。

https://www.postgresql.org/docs/9.5/static/sql-insert.html

如果没有列名的列表都被赋予,则默认为表在其声明的顺序中的所有列;或前N个列名称,如果只有N个列由VALUES子句或查询提供。

您可以改变插入来声明要插入的列的顺序,也可以更改选择的顺序以匹配表中列的顺序。

+0

多数民众赞成它!我将我的选择语句重新排序,现在它可以工作。这让我非常头疼。感谢你的回答 –