Knex.js를 사용한 대량 업데이트 레코드에 대한 QL 접근 방식

王林
풀어 주다: 2024-08-12 22:31:15
원래의
943명이 탐색했습니다.

QL Approaches to Bulk Update Records with Knex.js

웹 개발 세계에서는 특히 여러 레코드를 한 번에 업데이트하는 등 대량 작업을 처리할 때 데이터베이스를 효율적으로 작업하는 것이 중요합니다. 재고 관리, 사용자 데이터 처리, 거래 처리 등 효율적이고 안정적인 방식으로 대량 업데이트를 수행하는 능력은 필수적입니다.

이 가이드에서는 Node.js용 다목적 쿼리 빌더인 Knex.js를 사용하여 레코드를 대량 업데이트하는 세 가지 필수 SQL 기술을 분석합니다. 각 접근 방식은 다양한 시나리오에 맞게 조정되어 특정 사용 사례에 따라 뚜렷한 이점을 제공합니다. 우리가 다룰 내용:

  1. 여러 조건을 사용한 단일 업데이트:조건부 논리를 사용하여 특정 기준에 따라 다양한 업데이트를 적용하여 단일 쿼리로 여러 레코드를 업데이트할 수 있는 방법입니다.

  2. 트랜잭션에서 개별 쿼리를 사용한 일괄 업데이트:이 접근 방식은 트랜잭션을 활용하여 원자성을 보장하고 여러 업데이트 쿼리를 안전하고 효율적으로 실행합니다.

  3. Upsert(삽입 또는 업데이트) onContribute 사용:중복 데이터 위험 없이 새 레코드를 삽입하거나 기존 레코드를 업데이트해야 하는 시나리오에 이상적입니다.

다음 섹션에서는 이러한 각 방법에 대해 자세히 알아보고 구현, 이점 및 최상의 사용 사례를 검토합니다. 이러한 접근 방식을 이해하면 특정 요구 사항에 가장 적합한 기술을 선택하여 애플리케이션의 성능과 데이터 무결성을 모두 최적화할 수 있습니다.


1. 여러 조건을 사용한 단일 업데이트

데이터베이스의 여러 레코드를 업데이트하는 경우 효율성이 핵심입니다. 한 가지 강력한 기술은 여러 조건이 포함된 단일 UPDATE 쿼리를 사용하는 것입니다. 이 방법은 단일 SQL 문 내에서 특정 기준에 따라 다양한 레코드에 다양한 업데이트를 적용해야 할 때 특히 유용합니다.

콘셉트:

"여러 조건을 사용한 단일 업데이트" 접근 방식의 핵심 아이디어는 단일 UPDATE 쿼리를 사용하여 여러 행을 수정하고, 각 행은 잠재적으로 고유한 특성에 따라 서로 다른 값을 수신하는 것입니다. 이는 UPDATE 쿼리 내에서 CASE 문을 사용하여 달성되며 업데이트해야 하는 각 필드에 대해 조건부 논리를 지정할 수 있습니다.

이 접근 방식을 사용하는 이유:

  • 효율성:적은 수에서 중간 정도의 레코드 수(예: 수십에서 수백 개)의 경우 여러 업데이트를 단일 쿼리로 통합하면 데이터베이스 왕복 횟수를 줄여 성능을 크게 향상시킬 수 있습니다. 이는 빈도가 높은 업데이트를 처리할 때 특히 유용할 수 있습니다. 그러나 매우 큰 데이터 세트(수천 개 이상)의 경우 이 접근 방식이 효과적이지 않을 수 있습니다. 이 가이드의 뒷부분에서 대규모 데이터 세트를 처리하는 대체 방법에 대해 논의합니다.

  • 단순성:단일 쿼리로 업데이트를 관리하는 것이 여러 개의 개별 쿼리를 실행하는 것보다 더 간단하고 유지 관리하기 쉬운 경우가 많습니다. 이 접근 방식은 데이터베이스 상호 작용의 복잡성을 줄이고 특히 적당한 수의 업데이트를 처리할 때 코드를 더 쉽게 이해할 수 있게 해줍니다.

  • 오버헤드 감소:쿼리 수가 적다는 것은 데이터베이스에 대한 오버헤드가 적다는 것을 의미하며 이는 전반적인 성능을 향상시킬 수 있습니다. 이는 네트워크 대기 시간이나 데이터베이스 로드가 작업 속도에 영향을 미칠 수 있는 시나리오에서 특히 중요합니다.
    매우 많은 수의 레코드에 대해 이 가이드에서는 잠재적인 오버헤드를 보다 효과적으로 관리하기 위한 다른 전략을 살펴봅니다.

구현 예:

다음은 인기 있는 Node.js용 SQL 쿼리 빌더인 Knex.js를 사용하여 이 접근 방식을 구현하는 방법에 대한 실제 예입니다. 이 예에서는 조건부 논리를 사용하여 레코드 ID에 따라 다양한 업데이트를 적용하여 여러 레코드의 여러 필드를 한 번에 업데이트하는 방법을 보여줍니다.

으아악

이 코드의 역할:

  1. 쿼리 헤더 구성: 제품 테이블에 대한 UPDATE 문을 시작합니다.

  2. 조건부 업데이트 빌드: CASE 문을 사용하여 product_id를 기반으로 각 필드에 대해 서로 다른 업데이트를 지정합니다.

  3. 전체 쿼리 생성: 업데이트 문과 WHERE 절을 결합합니다.

  4. 쿼리 실행: 생성된 쿼리를 실행하여 지정된 레코드에 업데이트를 적용합니다.

이 기술을 구현하면 조건부 논리를 사용하여 대량 업데이트를 효율적으로 처리할 수 있어 데이터베이스 작업을 더욱 간소화하고 효과적으로 만들 수 있습니다.

Note: In the provided example, we did not use a transaction because the operation involves a single SQL query. Since a single query inherently maintains data integrity and consistency, there's no need for an additional transaction. Adding a transaction would only increase overhead without providing additional benefits in this context.

Having explored the "Single Update with Multiple Conditions" approach, which works well for a moderate number of records and provides simplicity and efficiency, we now turn our attention to a different scenario. As datasets grow larger or when atomicity across multiple operations becomes crucial, managing updates effectively requires a more robust approach.

Batch Updates with Individual Queries in a Transaction is a method designed to address these needs. This approach involves executing multiple update queries within a single transaction, ensuring that all updates are applied atomically. Let's dive into how this method works and its advantages.


2. Batch Updates with Individual Queries in a Transaction

When dealing with bulk updates, especially for a large dataset, managing each update individually within a transaction can be a robust and reliable approach. This method ensures that all updates are applied atomically and can handle errors gracefully.

Why Use This Approach:

  • Scalability:For larger datasets where Single Update with Multiple Conditions might become inefficient, batch updates with transactions offer better control. Each query is executed separately, and a transaction ensures that all changes are committed together, reducing the risk of partial updates.

  • Error Handling:Transactions provide a safety net by ensuring that either all updates succeed or none do. This atomicity guarantees data integrity, making it ideal for scenarios where you need to perform multiple related updates.

  • Concurrency Control:Using transactions can help manage concurrent modifications to the same records, preventing conflicts and ensuring consistency.

Code Example

Here’s how you can implement batch updates with individual queries inside a transaction using Knex.js:

const updateRecordsInBatch = async () => { // Example data to update const dataToUpdate = [ { id: 1, name: 'Updated Name 1', price: 100 }, { id: 2, name: 'Updated Name 2', price: 200 }, { id: 3, name: 'Updated Name 3', price: 300 } ]; // Start a transaction const trx = await db.transaction(); const promises = []; try { // Iterate over the data and push update queries to the promises array dataToUpdate.forEach(record => { promises.push( trx('products') .update({ name: record.name, price: record.price, updated_at: trx.fn.now() }) .where('id', record.id) ); }); // Execute all queries concurrently await Promise.all(promises); // Commit the transaction await trx.commit(); console.log('All records updated successfully.'); } catch (error) { // Rollback the transaction in case of error await trx.rollback(); console.error('Update failed:', error); } };
로그인 후 복사

Explanation

  1. Transaction Initialization: The transaction is started using db.transaction(), which ensures that all subsequent queries are executed within this transaction.

  2. Batch Updates: Each update query is constructed and added to an array of promises. This method allows for multiple updates to be performed concurrently.

  3. Executing Queries: Promise.all(promises) is used to execute all update queries concurrently. This approach ensures that all updates are sent to the database in parallel.

  4. Committing or Rolling Back: If all queries succeed, the transaction is committed with trx.commit(). If any query fails, the transaction is rolled back with trx.rollback(), ensuring that no partial updates are applied.

Using batch updates with individual queries inside a transaction provides a reliable way to manage large datasets. It ensures data integrity through atomic transactions and offers better control over concurrent operations. This method is especially useful whenSingle Update with Multiple Conditionsmay not be efficient for very large datasets.


3. Upsert (Insert or Update) Using onConflict

When you're working with data that might need to be inserted or updated depending on its existence in the database, an "upsert" operation is the ideal solution. This approach allows you to handle both scenarios—insert new records or update existing ones—in a single, streamlined operation. It's particularly useful when you want to maintain data consistency without having to write separate logic for checking whether a record exists.

Why Use This Approach:

  • Simplicity:An upsert enables you to combine the insert and update operations into a single query, simplifying your code and reducing the need for additional checks.

  • Efficiency:This method is more efficient than performing separate insert and update operations, as it minimizes database round-trips and handles conflicts automatically.

  • Conflict Handling:The onConflict clause lets you specify how to handle conflicts, such as when records with unique constraints already exist, by updating the relevant fields.

const productData = [ { product_id: 1, store_id: 101, product_name: 'Product A', price: 10.99, category: 'Electronics', }, { product_id: 2, store_id: 102, product_name: 'Product B', price: 12.99, category: 'Books', }, { product_id: 3, store_id: 103, product_name: 'Product C', price: 9.99, category: 'Home', }, { product_id: 4, store_id: 104, product_name: 'Product D', price: 15.49, category: 'Garden', }, ]; await knex('products') .insert(productData) .onConflict(['product_id', 'store_id']) .merge({ product_name: knex.raw('EXCLUDED.product_name'), price: knex.raw('EXCLUDED.price'), category: knex.raw('EXCLUDED.category'), });
로그인 후 복사

Explanation

  1. Definisi Data: Kami mentakrifkan productData, susunan objek yang mewakili rekod produk yang ingin kami masukkan atau kemas kini. Setiap objek mengandungi id_produk, id_kedai, nama_produk, harga dan kategori.

  2. Sisipkan atau Kemas Kini:Fungsi knex('products').insert(productData) cuba memasukkan setiap rekod daripada tatasusunanData produk ke dalam jadual produk.

  3. Kendalikan Konflik:Klausa onConflict(['product_id', 'store_id']) menyatakan bahawa jika konflik berlaku pada gabungan product_id dan store_id, langkah seterusnya hendaklah dilaksanakan.

  4. Gabung (Kemas kini tentang Konflik): Apabila konflik dikesan, kaedah gabungan({...}) mengemas kini rekod sedia ada dengan nilai_nama produk, harga dan kategori baharu daripada productData. Sintaks knex.raw('EXCLUDED.column_name') digunakan untuk merujuk kepada nilai yang akan dimasukkan, membenarkan pangkalan data mengemas kini rekod sedia ada dengan nilai ini.

Untuk klausaonConflictberfungsi dengan betul dalam operasiupsert, lajur yang terlibat mestilah sebahagian daripada kekangan unik. Begini cara ia berfungsi:

  • Lajur Unik Tunggal: Jika anda menggunakan satu lajur dalam klausa onConflict, lajur itu mestilah unik merentas jadual. Keunikan ini memastikan pangkalan data dapat mengesan dengan tepat sama ada rekod sudah wujud berdasarkan lajur ini.
  • Berbilang Lajur: Apabila berbilang lajur digunakan dalam klausa onConflict, gabungan lajur ini mestilah unik. Keunikan ini dikuatkuasakan oleh indeks atau kekangan unik, yang memastikan bahawa nilai gabungan lajur ini adalah unik merentas jadual.

Indeks dan Kekangan:
Indeks:Indeks unik pada satu atau lebih lajur membolehkan pangkalan data menyemak keunikan nilai dengan cekap. Apabila anda mentakrifkan indeks unik, pangkalan data akan menggunakannya untuk mengesahkan dengan cepat sama ada nilai dalam lajur yang ditentukan sudah wujud. Ini membolehkan klausa onConflict mengesan dan mengendalikan konflik dengan tepat.

Kekangan:Kekangan unik memastikan bahawa nilai dalam satu atau lebih lajur mestilah unik. Kekangan ini penting untuk klausa onConflict berfungsi, kerana ia menguatkuasakan peraturan yang menghalang nilai pendua dan membenarkan pangkalan data mengesan konflik berdasarkan lajur ini.

Sama seperti pendekatan Kemas Kini Tunggal dengan Pelbagai Syarat, operasi upsert tidak memerlukan transaksi. Memandangkan ia melibatkan satu pertanyaan yang sama ada memasukkan atau mengemas kini rekod, ia beroperasi dengan cekap tanpa overhed tambahan untuk menguruskan transaksi.


Kesimpulan

Setiap teknik memberikan kelebihan yang berbeza, daripada memudahkan kod dan mengurangkan interaksi pangkalan data kepada memastikan integriti data dan mengendalikan konflik dengan cekap. Dengan memilih kaedah yang paling sesuai untuk kes penggunaan anda, anda boleh mencapai kemas kini yang lebih cekap dan boleh dipercayai dalam aplikasi anda.

Memahami pendekatan ini membolehkan anda menyesuaikan operasi pangkalan data anda mengikut keperluan khusus anda, meningkatkan prestasi dan kebolehselenggaraan. Sama ada anda berurusan dengan kemas kini pukal atau tugas pengurusan data yang kompleks, memilih strategi yang betul adalah penting untuk mengoptimumkan aliran kerja anda dan mencapai hasil yang lebih baik dalam projek pembangunan anda.

위 내용은 Knex.js를 사용한 대량 업데이트 레코드에 대한 QL 접근 방식의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

원천:dev.to
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿
회사 소개 부인 성명 Sitemap
PHP 중국어 웹사이트:공공복지 온라인 PHP 교육,PHP 학습자의 빠른 성장을 도와주세요!