Received: from malur.postgresql.org ([217.196.149.56]) by arkaria.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384 (Exim 4.94.2) (envelope-from ) id 1srrcm-004zi8-RI for pgsql-general@arkaria.postgresql.org; Sat, 21 Sep 2024 04:21:37 +0000 Received: from localhost ([127.0.0.1] helo=malur.postgresql.org) by malur.postgresql.org with esmtp (Exim 4.94.2) (envelope-from ) id 1srrci-00E3K6-Ud for pgsql-general@arkaria.postgresql.org; Sat, 21 Sep 2024 04:21:34 +0000 Received: from magus.postgresql.org ([2a02:c0:301:0:ffff::29]) by malur.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384 (Exim 4.94.2) (envelope-from ) id 1srrci-00E3Jr-HV for pgsql-general@lists.postgresql.org; Sat, 21 Sep 2024 04:21:33 +0000 Received: from mail-wm1-x330.google.com ([2a00:1450:4864:20::330]) by magus.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256 (Exim 4.94.2) (envelope-from ) id 1srrcb-000IHv-TW for pgsql-general@lists.postgresql.org; Sat, 21 Sep 2024 04:21:32 +0000 Received: by mail-wm1-x330.google.com with SMTP id 5b1f17b1804b1-42cb6f3a5bcso32260635e9.2 for ; Fri, 20 Sep 2024 21:21:27 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=kleczek.org; s=google; t=1726892486; x=1727497286; darn=lists.postgresql.org; h=to:references:message-id:content-transfer-encoding:cc:date :in-reply-to:from:subject:mime-version:from:to:cc:subject:date :message-id:reply-to; bh=KS9qqrRdfaZEJ6SPugyuepJ5wWdk1x6GQyjHEIXghLs=; b=if57268Q9mVd18ij3XvfPG0fQ1YDUmyAueSvgewOxDABSNr2HnBrCAZDnrubSmURzj QiVMj6V3xJYr2L0UvUw2QFriubVcBnRK4tv5d/vr3FNerOXuXIJfIvsfFCAWJisFwcoM G9U9l5xMJGKZ8bxeil34v/zFr0zYD/uE+nYZk= X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20230601; t=1726892486; x=1727497286; h=to:references:message-id:content-transfer-encoding:cc:date :in-reply-to:from:subject:mime-version:x-gm-message-state:from:to:cc :subject:date:message-id:reply-to; bh=KS9qqrRdfaZEJ6SPugyuepJ5wWdk1x6GQyjHEIXghLs=; b=bIaSE53zSe2Jerw+M3ie51zsOBDExp24TMs8P1AVgfJugvS0SKEsTwwcB9a0wOROAc QcT9+NCwElutnIYfheprb/p5CoNuWrHJlNNkVZYYNom6z+oVysPng0uiFUouapAH8h9F 4yVzvKEDwU/nrDRK0ygj4L7Dwq3E9xVEkLv3aeDeqeN4XfEcd/PqV0EmfT2Wq+0cYb3N yuPmCDG2uKAIS/hYsegEgZIwZIGXJqRXzEKp4kx8d2YBzS73lClm6FUuB70+2eSS547U YBYuvdBOuV0V9cpdghVMOar9ex12bEaCLpzjT8H01bZN+OdVB8jPm8RSTSzVhRgUrzNN rk6w== X-Gm-Message-State: AOJu0Yzpzu2+6++SB1gWWYYMSU5XDsZXQqr/Oooclg29UqA73z7SSZ4B XObr/4ag9hFUZ5yA5RjXChtXfhSBLpUDhH0WmgD2p5e17FUocamabaUU6N3ZQdo= X-Google-Smtp-Source: AGHT+IHZcJNdcrEYuwvJKokMvlXIpBYzVu+7MM2UrtngpeBAedGwu6w1ZuFDGsKGF9YQtW+uyz2OfA== X-Received: by 2002:a5d:5501:0:b0:374:c3cd:73de with SMTP id ffacd0b85a97d-37a422ea0a4mr4290204f8f.35.1726892485754; Fri, 20 Sep 2024 21:21:25 -0700 (PDT) Received: from smtpclient.apple (b15.kleczek.org. [185.20.172.182]) by smtp.gmail.com with ESMTPSA id a640c23a62f3a-a90612df5cfsm939964766b.146.2024.09.20.21.21.23 (version=TLS1_2 cipher=ECDHE-ECDSA-AES128-GCM-SHA256 bits=128/128); Fri, 20 Sep 2024 21:21:24 -0700 (PDT) Content-Type: text/plain; charset=utf-8 Mime-Version: 1.0 (Mac OS X Mail 16.0 \(3776.700.51\)) Subject: Re: How batch processing works From: =?utf-8?Q?Micha=C5=82_K=C5=82eczek?= In-Reply-To: Date: Sat, 21 Sep 2024 06:21:12 +0200 Cc: pgsql-general Content-Transfer-Encoding: quoted-printable Message-Id: <4178E73A-24F5-4E3C-92F6-1532D8102C3E@kleczek.org> References: To: Lok P X-Mailer: Apple Mail (2.3776.700.51) List-Id: List-Help: List-Subscribe: List-Post: List-Owner: List-Archive: Archived-At: Precedence: bulk Hi, > On 19 Sep 2024, at 07:30, Lok P wrote: >=20 [snip] >=20 > Method-4 >=20 > INSERT INTO parent_table VALUES (1, 'a'), (2, 'a'); > INSERT INTO child_table VALUES (1,1, 'a'), (1,2, 'a'); > commit; I=E2=80=99ve done some batch processing of JSON messages from Kafka in = Java. By far the most performant way was to: 1. Use prepared statements 2. Parse JSON messages in Postgres 3. Process messages in batches All three can be achieved by using arrays to pass batches: WITH parsed AS ( SELECT msg::json FROM unnest(?) ), parents AS ( INSERT INTO parent SELECT =E2=80=A6 FROM parsed RETURNING ... ) INSERT INTO child SELECT =E2=80=A6 FROM parsed=E2=80=A6 Not the single parameter that you can bind to String[] Hope that helps. -- Michal=