postgresmen/postgresqlrussia

#PostgreSQLRussia channel http://postgres.chat. JOIN us: http://PostgreSQLRussia.org

Alexander Nikolaev

@startaper

и еще http://postgres.chat/ пишет что This Domain Name Has Expired

nolka

@nolka

Привет всем :)

Помогите нубу пожалуйста :)

Есть громадная таблица категорий :)

Нужно вывести эту иерархию в красивом человекочитаемом виде в идеале :)

типа, root -> leaf1 -> leaf2 ->leaf3

для каждой из категорий

И я словил жесткий тупняк в этом месте :(

Yury Zhuravlev

@stalkerg

смотря как это всё лежит в бд

а так рекурсия твой друг

Nikolay Samokhvalov

@NikolayS

типа, root -> leaf1 -> leaf2 ->leaf3

1) Можно использовать модуль ltree, который специально для деревьев https://www.postgresql.org/docs/current/static/ltree.html

2) Можно просто реляции и recursive CTE, получится breadth-first search; вот простой пример http://jakub.fedyczak.net/post/postgresql-with-recursive-tree-traversing-example/ (или погуглите ещё "breadth-first search postgresql", я помню что не раз статьи были, более глубокие чем эта)

3) Есть ещё целая книжка, как в SQL работать с графами и деревьями, у Joe Celko https://datubaze.files.wordpress.com/2016/03/celkos-trees-and-hierarchies-in-sql_2004.pdf – это старый вариант, было ещё второе издание.

п.2 -- это standard ansi sql. у Celko не знаю, есть ли варианты с CTE.
п1. -- это чисто постгресовое, но довольно эффективное, т.к. с GiST-индексами.

Ага , вижу, что у Celko во втором издании есть глава 2.4. 3 Recursive CTEs.

Andreo1111

@Andreo1111

всем привет

кто нибудь barman настраивал для работы со slave ? (postgres v9.3)

Roman

@DoctorLines

Всем привет!

Есть довольно простой запрос:

select
    *
from
    "gateways_status_history"
where
    "identifier" = '11:11:11:11:11:11'
or 
    "id" = 99
order by
    "updated_at" desc

Таких записей в таблице нету, по этому ожидается что ничего не найдет

но, он находит запись с совершенно другим identifier и id

Кто может объяснить, как это черт возьми работает ?)))

postgres v9.3

Roman

@DoctorLines

А, это я дурак, колонку попутал

Что за магия такая, пока не спросишь кого-нибудь, проблемы не решаются

Dmitry Bochkarev

@DmitryBochkarev

Привет, а может кто подсказать - если в функции есть raise может она считаться stable? https://www.postgresql.org/docs/10/static/xfunc-volatility.html

Андрианов Сергей

@Batisska

Ребята подскажите как решить задачу. Есть 2 сервера с Postgresql 10 с идентичными базами данных. Требуется с первого сервера ежедневно(ежечасно, в релтайме) копировать несколько таблиц в на второй а со второго на первый другие таблицы копировать. Таблицы между собой связаны. Подскажите какие есть способы реализации данной задачи.

если проще мне с прода надо копировать заказы с заказчиками, а с дублирующего сервака информацию о продуктах каталогах и так далее

Nikolay Samokhvalov

@NikolayS

@Batisska Самое простое: убрать FK, использовать логическую репликацию

Андрианов Сергей

@Batisska

Ребят подскажите как отдебажить проблему. У меня имеется 2 докер контейнера один в локальной сети другой во внешней. Установлены с одного хаба с одним и тем же конфигом. Через MS Access идут запросы к базе данных. На локальный сервак они проходят за 6 минут, а на внешний за 21 минут. Как можно найти причину увеличение времени?

AlexeyMozgo

@AlexeyMozgo

Всем привет.

Работал кто-нибудь с Stolon?

Rustem Zhumagulov

@antFerda

Привет всем! Подскажите пожалуйста ETL тул для заливки в Postgres из 2 - 3 источников. XLS, БД и LDAP сервер как источники

Nhung Phạm Hồng

@nhungphamhong

Hi all, can you speak English?

i want to ask you some questions

So i can't understand you're saying

vedun

@vedun

приветствую
подскажите можно как то извлечь двоичное представление из колонки с типом double precision ?

venkat125

@venkat125

hi there, I'm trying to connect diesel orm with postgres Enterprise DB version 11. But couldn't setup "diesel setup" in cmd which throws error as follows: diesel.exe - Ordinal Not Found
Refer this link for more details: https://stackoverflow.com/questions/53456457/diesel-exe-ordinal-not-found-the-ordinal-4701-could-not-be-located-in-the-dy

Constantine

@unk2k

Hi all. I have a table with 2 varchar columns. I want to create an index using GIN and using JSON of 2 columns.
create index test on test using gin (to_json(array[col1, col2])); but I catch an exception ERROR: functions in index expression must be marked IMMUTABLE. How can create the index correct?

dsx90

@dsx90

Всем привет! Подскажите как улучшить и сделать красивее данный запрос. SQL я только изучаю. Так что прошу камнями сильно не закидывать)

SELECT
       a.stock_name                                        AS stock_name,
       a.delivery_time                                     AS delivery_time,
       a.sum_amount                                        AS all,
       r.sum_amount                                        AS refusal,
       n.sum_amount                                        AS normal,
       r.sum_amount :: real / a.sum_amount :: real * 100   AS percent
FROM (
     SELECT
            accepted.name as stock_name,
            sum(accepted.amount) as sum_amount,
            accepted.delivery_time
     FROM (
          SELECT
                 order_product_status_history.order_product_id as product,
                 stock.name                                    as name,
                 order_product.amount                          AS "amount",
                 order_product_status_history.date_added       AS date,
                 delivery_time                                 as delivery_time
          FROM "order_product"
                 LEFT JOIN "order" ON "order_product"."order_id" = "order"."id"
                 LEFT JOIN "customer" ON "order"."customer_id" = "customer"."id"
                 LEFT JOIN "customer_group" ON "customer"."customer_group_id" = "customer_group"."id"
                 LEFT JOIN "stock_product" ON "order_product"."stock_product_id" = "stock_product"."id"
                 LEFT JOIN "stock" ON "stock_product"."stock_id" = "stock"."id"
                 LEFT JOIN "organization" ON "order"."pvz_id" = "organization"."id"
                 LEFT JOIN order_product_status_history on order_product.id = order_product_status_history.order_product_id
          WHERE (NOT ("order"."status" IN (8, 10)))
            AND "order".date_added > '2018-07-01'::date
            AND order_product_status_history.status = 14372--STATUS_ACCEPTED
          ) AS accepted
            inner join (
                       SELECT
                              order_product_status_history.order_product_id as product,
                              stock.name                                    as name,
                              order_product.amount                          AS "amount",
                              order_product_status_history.date_added       AS date,
                              delivery_time                                 as delivery_time
                       FROM "order_product"
                              LEFT JOIN "order" ON "order_product"."order_id" = "order"."id"
                              LEFT JOIN "customer" ON "order"."customer_id" = "customer"."id"
                              LEFT JOIN "customer_group" ON "customer"."customer_group_id" = "customer_group"."id"
                              LEFT JOIN "stock_product" ON "order_product"."stock_product_id" = "stock_product"."id"
                              LEFT JOIN "stock" ON "stock_product"."stock_id" = "stock"."id"
                              LEFT JOIN "organization" ON "order"."pvz_id" = "organization"."id"
                              LEFT JOIN order_product_status_history on order_product.id = order_product_status_history.order_product_id
                       WHERE (NOT ("order"."status" IN (8, 10)))
                         AND "order".date_added > '2018-07-01'::date
                         AND order_product_status_history.status = 4947--STATUS_IN_STOCK
                       ) AS r ON accepted.product = r.product
     group by stock_name, accepted.delivery_time
     ) as a
       left join (
                 SELECT
                        accepted.name         AS stock_name,
                        SUM(accepted.amount)  AS sum_amount
                 FROM (
                      SELECT
                             order_product_status_history.order_product_id as product,
                             stock.name                                    as name,

order_product.amount                          AS "amount",
                             order_product_status_history.date_added       AS date,
                             delivery_time                                 as delivery_time
                      FROM "order_product"
                             LEFT JOIN "order" ON "order_product"."order_id" = "order"."id"
                             LEFT JOIN "customer" ON "order"."customer_id" = "customer"."id"
                             LEFT JOIN "customer_group" ON "customer"."customer_group_id" = "customer_group"."id"
                             LEFT JOIN "stock_product" ON "order_product"."stock_product_id" = "stock_product"."id"
                             LEFT JOIN "stock" ON "stock_product"."stock_id" = "stock"."id"
                             LEFT JOIN "organization" ON "order"."pvz_id" = "organization"."id"
                             LEFT JOIN order_product_status_history on order_product.id = order_product_status_history.order_product_id
                      WHERE (NOT ("order"."status" IN (8, 10)))
                        AND "order".date_added > '2018-07-01'::date
                        AND order_product_status_history.status = 14372--STATUS_ACCEPTED
                      ) AS accepted
                        inner join (
                                   SELECT
                                          order_product_status_history.order_product_id as product,
                                          stock.name                                    as name,
                                          order_product.amount                          AS "amount",
                                          order_product_status_history.date_added       AS date,
                                          CASE
                                            WHEN EXTRACT (dow FROM order_product_status_history.date_added) IN (6) THEN order_product_status_history.date_added + interval '2 day'
                                            WHEN EXTRACT (dow FROM order_product_status_history.date_added) IN (0) THEN order_product_status_history.date_added + interval '1 day'
                                            ELSE order_product_status_history.date_added
                                              END as dw,
                                          delivery_time                                 as delivery_time
                                   FROM "order_product"
                                          LEFT JOIN "order" ON "order_product"."order_id" = "order"."id"
                                          LEFT JOIN "customer" ON "order"."customer_id" = "customer"."id"
                                          LEFT JOIN "customer_group" ON "customer"."customer_group_id" = "customer_group"."id"
                                          LEFT JOIN "stock_product" ON "order_product"."stock_product_id" = "stock_product"."id"
                                          LEFT JOIN "stock" ON "stock_product"."stock_id" = "stock"."id"
                                          LEFT JOIN "organization" ON "order"."pvz_id" = "organization"."id"
                                          LEFT JOIN order_product_status_history on order_product.id = order_product_status_history.order_product_id
                                   WHERE (NOT ("order"."status" IN (8, 10)))
                                     AND "order".date_added > '2018-07-01'::date
                                     AND order_product_status_history.status = 4947--STATUS_IN_STOCK
                                   ) AS r ON accepted.product = r.product
                 WHERE EXTRACT(EPOCH FROM (r.dw - accepted.date)) / 60 / 60 <= accepted.delivery_time + 6
                 group by stock_name
                 ) as n on a.stock_name = n.stock_name
       inner join (
                  SELECT
                         accepted.name         AS stock_name,
                         SUM(accepted.amount)  AS sum_amount
                  from (
                       SELECT

order_product_status_history.date_added       AS date,
                              delivery_time                                 as delivery_time
                       FROM "order_product"
                              LEFT JOIN "order" ON "order_product"."order_id" = "order"."id"
                              LEFT JOIN "customer" ON "order"."customer_id" = "customer"."id"
                              LEFT JOIN "customer_group" ON "customer"."customer_group_id" = "customer_group"."id"
                              LEFT JOIN "stock_product" ON "order_product"."stock_product_id" = "stock_product"."id"
                              LEFT JOIN "stock" ON "stock_product"."stock_id" = "stock"."id"
                              LEFT JOIN "organization" ON "order"."pvz_id" = "organization"."id"
                              LEFT JOIN order_product_status_history on order_product.id = order_product_status_history.order_product_id
                       WHERE (NOT ("order"."status" IN (8, 10)))
                         AND "order".date_added > '2018-07-01'::date
                         AND order_product_status_history.status = 14372--STATUS_ACCEPTED
                       ) AS accepted
                         inner join (
                                    SELECT
                                           order_product_status_history.order_product_id as product,
                                           stock.name                                    as name,
                                           order_product.amount                          AS "amount",
                                           order_product_status_history.date_added       AS date,
                                           CASE
                                             WHEN EXTRACT (dow FROM order_product_status_history.date_added) IN (6) THEN order_product_status_history.date_added + interval '2 day'
                                             WHEN EXTRACT (dow FROM order_product_status_history.date_added) IN (0) THEN order_product_status_history.date_added + interval '1 day'
                                             ELSE order_product_status_history.date_added
                                               END as dw,
                                           delivery_time                                 as delivery_time
                                    FROM "order_product"
                                           LEFT JOIN "order" ON "order_product"."order_id" = "order"."id"
                                           LEFT JOIN "customer" ON "order"."customer_id" = "customer"."id"
                                           LEFT JOIN "customer_group" ON "customer"."customer_group_id" = "customer_group"."id"
                                           LEFT JOIN "stock_product" ON "order_product"."stock_product_id" = "stock_product"."id"
                                           LEFT JOIN "stock" ON "stock_product"."stock_id" = "stock"."id"
                                           LEFT JOIN "organization" ON "order"."pvz_id" = "organization"."id"
                                           LEFT JOIN order_product_status_history on order_product.id = order_product_status_history.order_product_id
                                    WHERE (NOT ("order"."status" IN (8, 10)))
                                      AND "order".date_added > '2018-07-01'::date
                                      AND order_product_status_history.status = 4947--STATUS_IN_STOCK
                                    ) AS r ON accepted.product = r.product
                  where extract(epoch from (r.dw - accepted.date)) / 60 / 60 > accepted.delivery_time + 6
                  group by stock_name
                  ) as r on a.stock_name = r.stock_name

dimtabu

@taburetkin

вопрос

  CREATE TYPE someType AS
  (
    sometext character varying(128),
    somenum smallint,
  );

  CREATE TABLE "sometable "
  (
      id uuid NOT NULL default uuid_generate_v4() PRIMARY KEY,
      someField someType
  )

можно ли делать параметризированый инсерт вот так?

insert into sometable (someCompositeField) values ($1)

и если да то что должно быть в виде параметра ? массив, Josn или строка row('text', 123)

не могу отыскать пример

dimtabu

@taburetkin

отыскал

Erjan

@erjan

привет, кто знает как сделать так чтоб мой rest api писал каждый входящий запрос в базу postgre? как их соединить?

Alexander Mirniy

@LidiyaPetrovna_gitlab

привет, кто знает как сделать так чтоб мой rest api писал каждый входящий запрос в базу postgre? как их соединить?

Месье, хоть ответ просрочен, может, брокер сообщений вам поможет - RabbitMQ или Kafka. К тому же, с ними в любом случае неплохо разобраться

Вопрос:
кручу psql через docker-compose, вот .yml:
version: '3'
services:
postgres:
image: 'postgres'
ports:

  - "5432:5432"
environment:
    - POSTGRES_DB=db_2020
    - POSTGRES_USER=dbuser_2020
    - POSTGRES_PASSWORD=minecraft2000

вот настройки джанго, джанго не в контейнере, просто на системе :
DATABASES = {
'default': {
'ENGINE': 'django.db.backends.postgresql_psycopg2',
'NAME': 'db_2020',
'USER': 'db_user2020',
'PASSWORD': 'minecraft2000',
'HOST': '0.0.0.0',
'PORT': '5432',
}

}

джанго пишет : django.db.utils.OperationalError: FATAL: password authentication failed for user "db_user2020"
Может, кто подскажет чего?

savickiyav

@savickiyav

подскажите пожалуйста. нужно выполнить скрипт. на sql он будет выглядеть так:

DECLARE @i int = 100
WHILE @i < 10100
BEGIN
INSERT INTO public.products(
product_id, product_name, discontinued)
VALUES (@i, @i,1);
set @i = @i+1
END

как его запустить на pgsql

kr1929uti

@kr1929uti

Hi everyone, I have a kafka setup with postgres as my source and sink. I am trying to implement a scenario where any ddl changes in postgres source connector (such as column addition, deletion, update on column, column type change) should reflect in my sink postgres table. I already have auto.evolve=true in my sink connector configuration (using JDBC sink connector), but it is not fulfilling the requirements. Any suggestion on this?

kr1929uti

@kr1929uti

Hi all,
Whenever I encounter schema changes (ddl changes coming in), I want to automate the table backup and table deletion and then table creation with the new schema. (I am using postgres db and I have kafka setup). Any suggestions on how to go about automation?

Where communities thrive

People

Repo info

Activity

}