דילוג לתוכן
  • דף הבית
  • קטגוריות
  • פוסטים אחרונים
  • משתמשים
  • חיפוש
  • חוקי הפורום
כיווץ
תחומים

תחומים - פורום חרדי מקצועי

💡 רוצה לזכור קריאת שמע בזמן? לחץ כאן!
  1. דף הבית
  2. תכנות
  3. מניעת race condition ב-DB

מניעת race condition ב-DB

מתוזמן נעוץ נעול הועבר תכנות
42 פוסטים 7 כותבים 1.1k צפיות 6 עוקבים
  • מהישן לחדש
  • מהחדש לישן
  • הכי הרבה הצבעות
תגובה
  • תגובה כנושא
התחברו כדי לפרסם תגובה
נושא זה נמחק. רק משתמשים עם הרשאות מתאימות יוכלו לצפות בו.
  • clickoneC clickone

    @yossiz לכאורה טריגר הוא הפיתרון הנכון כאן
    אם כי אני כמעט מעולם לא השתמשתי בטריגר (למעט הכרה שלו)
    יש מקרה אחד ויחיד שבו עד היום השתמשתי בטריגר, וגם זה היה מחוסר ברירה ולא מבחירה
    (יכול להיות שאני טועה בזה, אבל אני לא אוהב להשתמש בזה)

    מה מפריע לך בעידכון של שאילתת משנה?

    update orgs set lastCharge=(
    select max(chargeId) from charges where orgId=orges.orgeId
    ) where orgeId=?
    
    yossizY מנותק
    yossizY מנותק
    yossiz
    כתב ב נערך לאחרונה על ידי
    #8

    @clickone אמר במניעת race condition ב-DB:

    מה מפריע לך בעידכון של שאילתת משנה?

    אין לי שום בעיה עם זה. זה לכאורה פתרון מצויין, אבל אני רוצה גם ללמוד פתרונות לבעיה במקומות שבהם פתרון זה לא יהיה מעשי.
    (חוץ מזה אני לא יודע עדיין איך לעשות שאילתת משנה ב-SEQUELIZE 🤦 אבל זה אני יכול ללמוד בקלות)
    גם אשמח להבין אם פתרון זה הוא זהה (ברמת מתחת למכסה) לאחד מהפתרונות האחרות (האם יש נעילה? טרנזקציה באיזה רמת בידוד?)

    📧 יוסי@מייל.קום | 🌎 בלוג | ☕ קפה

    clickoneC תגובה 1 תגובה אחרונה
    2
    • yossizY yossiz

      @clickone אמר במניעת race condition ב-DB:

      מה מפריע לך בעידכון של שאילתת משנה?

      אין לי שום בעיה עם זה. זה לכאורה פתרון מצויין, אבל אני רוצה גם ללמוד פתרונות לבעיה במקומות שבהם פתרון זה לא יהיה מעשי.
      (חוץ מזה אני לא יודע עדיין איך לעשות שאילתת משנה ב-SEQUELIZE 🤦 אבל זה אני יכול ללמוד בקלות)
      גם אשמח להבין אם פתרון זה הוא זהה (ברמת מתחת למכסה) לאחד מהפתרונות האחרות (האם יש נעילה? טרנזקציה באיזה רמת בידוד?)

      clickoneC מנותק
      clickoneC מנותק
      clickone
      כתב ב נערך לאחרונה על ידי
      #9

      @yossiz
      אני לא מכיר את postgres, אבל אני חושב שזה שווה ערך ל4 והוא עושה את 2 הפקודות ביחד, ולכאורה זה נועל את הDB

      אני מנסה קודם להבין את הצורך
      כמו שכתב @dovid , בד"כ משתמשים במיספור אוטומטי, למה זה לא המצב אצלך?
      אא"כ (שזה מה ששאני מריח) שזה טבלה כמו של חשבוניות / קבלות ואתה צריך לדעת את המספר האחרון שיצא
      ועדיין, לא הבנתי למה אתה שומר את הנתון הזה סטטי בorgs, במקום להביא אותו מחושב באותו הרגע שתצטרך?
      ז"א, במקום למשוך את זה מהטבלה, וללכת ולחזור, אתה פשוט מוסיף את הנתונים בinsert ואז מיד את המס' אתה מכניס עם sub query

      INSERT INTO charge
      (
      docNumber,
      name,
      amount
      )
      VALUES
      (
      (select max(chargeId) from charges where orgId=?) as docNumber,
      "yossiz" as name,
      100 as amount
      )
      

      שים לב שאני כותב את השאילתא ישר לכאן ללא בדיקה אז יכול להיות טעויות

      אין טסט כמו פרודקשן.

      המייל שלי urivpn@gmail.com

      yossizY תגובה 1 תגובה אחרונה
      0
      • clickoneC clickone

        @yossiz
        אני לא מכיר את postgres, אבל אני חושב שזה שווה ערך ל4 והוא עושה את 2 הפקודות ביחד, ולכאורה זה נועל את הDB

        אני מנסה קודם להבין את הצורך
        כמו שכתב @dovid , בד"כ משתמשים במיספור אוטומטי, למה זה לא המצב אצלך?
        אא"כ (שזה מה ששאני מריח) שזה טבלה כמו של חשבוניות / קבלות ואתה צריך לדעת את המספר האחרון שיצא
        ועדיין, לא הבנתי למה אתה שומר את הנתון הזה סטטי בorgs, במקום להביא אותו מחושב באותו הרגע שתצטרך?
        ז"א, במקום למשוך את זה מהטבלה, וללכת ולחזור, אתה פשוט מוסיף את הנתונים בinsert ואז מיד את המס' אתה מכניס עם sub query

        INSERT INTO charge
        (
        docNumber,
        name,
        amount
        )
        VALUES
        (
        (select max(chargeId) from charges where orgId=?) as docNumber,
        "yossiz" as name,
        100 as amount
        )
        

        שים לב שאני כותב את השאילתא ישר לכאן ללא בדיקה אז יכול להיות טעויות

        yossizY מנותק
        yossizY מנותק
        yossiz
        כתב ב נערך לאחרונה על ידי yossiz
        #10

        @clickone נראה לי שאנחנו לא משדרים באותו תדר...
        מספר ה-charge שמור בטבלת ה-charges לא עם ה-org.
        כדי לקבל את המספר הבא אני מושך את המספר הגבוהה ביותר של ארגון זה ומוסיף עליו עוד אחד.

        ועדיין, לא הבנתי למה אתה שומר את הנתון הזה סטטי בorgs, במקום להביא אותו מחושב באותו הרגע שתצטרך?

        ז"א, במקום למשוך את זה מהטבלה, וללכת ולחזור, אתה פשוט מוסיף את הנתונים בinsert ואז מיד את המס' אתה מכניס עם sub query

        זה בדיוק מה שהתכוונתי בפתרון מס' 4. (וזה מה שחשבתי שאתה מתכוון בפוסט הראשון שלך, עכשיו קראתי שוב ואני רואה שלא הבנת את מבנה ה-DB נכון)
        ואני עדיין רוצה להבין מה רמת הנעילה שזה עושה, האם זה נועל את כל הטבלה למשך הרצת הפקודה או שרק הוספת שורות עבור אותו ארגון.

        📧 יוסי@מייל.קום | 🌎 בלוג | ☕ קפה

        clickoneC תגובה 1 תגובה אחרונה
        1
        • yossizY yossiz

          @clickone נראה לי שאנחנו לא משדרים באותו תדר...
          מספר ה-charge שמור בטבלת ה-charges לא עם ה-org.
          כדי לקבל את המספר הבא אני מושך את המספר הגבוהה ביותר של ארגון זה ומוסיף עליו עוד אחד.

          ועדיין, לא הבנתי למה אתה שומר את הנתון הזה סטטי בorgs, במקום להביא אותו מחושב באותו הרגע שתצטרך?

          ז"א, במקום למשוך את זה מהטבלה, וללכת ולחזור, אתה פשוט מוסיף את הנתונים בinsert ואז מיד את המס' אתה מכניס עם sub query

          זה בדיוק מה שהתכוונתי בפתרון מס' 4. (וזה מה שחשבתי שאתה מתכוון בפוסט הראשון שלך, עכשיו קראתי שוב ואני רואה שלא הבנת את מבנה ה-DB נכון)
          ואני עדיין רוצה להבין מה רמת הנעילה שזה עושה, האם זה נועל את כל הטבלה למשך הרצת הפקודה או שרק הוספת שורות עבור אותו ארגון.

          clickoneC מנותק
          clickoneC מנותק
          clickone
          כתב ב נערך לאחרונה על ידי
          #11

          @yossiz
          ואין לך דרך לדעת מי קשור לאותו ORG?
          אם כן, למה זה ככה? (מוזר לי שאתה מתבסס על הORG אבל אין עמודה שלו בטבלה השנייה)

          כנראה אני אכן מפספס כאן משהו מאד מהותי
          תוכל להסביר יותר מה הקשרים בין הטבלאות?

          אין טסט כמו פרודקשן.

          המייל שלי urivpn@gmail.com

          yossizY תגובה 1 תגובה אחרונה
          0
          • clickoneC clickone

            @yossiz
            ואין לך דרך לדעת מי קשור לאותו ORG?
            אם כן, למה זה ככה? (מוזר לי שאתה מתבסס על הORG אבל אין עמודה שלו בטבלה השנייה)

            כנראה אני אכן מפספס כאן משהו מאד מהותי
            תוכל להסביר יותר מה הקשרים בין הטבלאות?

            yossizY מנותק
            yossizY מנותק
            yossiz
            כתב ב נערך לאחרונה על ידי yossiz
            #12

            @clickone עזוב טבלאות אחרות, בטעות הזכרתי שיש טבלה של org.
            יש רק טבלה אחת של charges עם 3 עמודות (שקשורות לנושא שלנו): id, orgId, chargeNumber
            ה-chargenumber אמור להיות מספר ה-charge לפי הארגון. זה לא יכול להיות autoincrement כי אפשר שתיים עם אותו מספר כאשר הם משוייכים לארגון אחר

            📧 יוסי@מייל.קום | 🌎 בלוג | ☕ קפה

            clickoneC chagoldC 2 תגובות תגובה אחרונה
            0
            • yossizY yossiz

              @clickone עזוב טבלאות אחרות, בטעות הזכרתי שיש טבלה של org.
              יש רק טבלה אחת של charges עם 3 עמודות (שקשורות לנושא שלנו): id, orgId, chargeNumber
              ה-chargenumber אמור להיות מספר ה-charge לפי הארגון. זה לא יכול להיות autoincrement כי אפשר שתיים עם אותו מספר כאשר הם משוייכים לארגון אחר

              clickoneC מנותק
              clickoneC מנותק
              clickone
              כתב ב נערך לאחרונה על ידי
              #13

              @yossiz אמר במניעת race condition ב-DB:

              ה-chargenumber אמור להיות מספר ה-charge של הארגון.

              שזה תמיד האחרון שנכנסם + 1?
              או שזה מספר קבוע?
              כעת אני כן רואה שאתה כותב שיש בטבלה orgid

              אין טסט כמו פרודקשן.

              המייל שלי urivpn@gmail.com

              yossizY תגובה 1 תגובה אחרונה
              1
              • clickoneC clickone

                @yossiz אמר במניעת race condition ב-DB:

                ה-chargenumber אמור להיות מספר ה-charge של הארגון.

                שזה תמיד האחרון שנכנסם + 1?
                או שזה מספר קבוע?
                כעת אני כן רואה שאתה כותב שיש בטבלה orgid

                yossizY מנותק
                yossizY מנותק
                yossiz
                כתב ב נערך לאחרונה על ידי yossiz
                #14

                @clickone אמר במניעת race condition ב-DB:

                שזה תמיד האחרון שנכנסם + 1?

                בדיוק, אבל האחרון של ארגון זה, לא של כל הטבלה

                📧 יוסי@מייל.קום | 🌎 בלוג | ☕ קפה

                clickoneC תגובה 1 תגובה אחרונה
                0
                • yossizY yossiz

                  @clickone אמר במניעת race condition ב-DB:

                  שזה תמיד האחרון שנכנסם + 1?

                  בדיוק, אבל האחרון של ארגון זה, לא של כל הטבלה

                  clickoneC מנותק
                  clickoneC מנותק
                  clickone
                  כתב ב נערך לאחרונה על ידי
                  #15

                  @yossiz
                  אז מצויין, זה מה שכתבתי בדוגמא הזו
                  (תחליף את docNumber ב chargeNumber)

                  INSERT INTO charge
                  (
                  docNumber,
                  name,
                  amount
                  )
                  VALUES
                  (
                  (select max(chargeId) from charges where orgId=?) as docNumber,
                  "yossiz" as name,
                  100 as amount
                  )
                  

                  ואתה התכוונת אליו למעלה, לא?
                  לכאורה בשיטה הזו הוא ינעל את השינויים כי זה נעשה בפעם אחת

                  אין טסט כמו פרודקשן.

                  המייל שלי urivpn@gmail.com

                  תגובה 1 תגובה אחרונה
                  1
                  • clickoneC מנותק
                    clickoneC מנותק
                    clickone
                    כתב ב נערך לאחרונה על ידי clickone
                    #16

                    כאן
                    https://stackoverflow.com/questions/39498675/how-to-create-an-auto-increment-column-that-is-segmented-by-an-other-column
                    לכאורה הוא פתר את זה עם טריגר ולכאורה זה הנכון
                    (זה נראה MSSQL אבל לא התעמקתי)

                    אין טסט כמו פרודקשן.

                    המייל שלי urivpn@gmail.com

                    תגובה 1 תגובה אחרונה
                    1
                    • clickoneC מנותק
                      clickoneC מנותק
                      clickone
                      כתב ב נערך לאחרונה על ידי
                      #17

                      סליחה שאני שם כאן כ"כ הרבה מראי מקומות 😮
                      מאד תמוה בעצם שאין דבר כזה מובנה כי זה דבר די נפוץ מה שאתה מנסה לעשות
                      אבל ראיתי שזה קיים בmysql אבל רק עם המנוע MyISAM
                      https://dba.stackexchange.com/questions/19019/mysql-get-next-unique-value-without-auto-increment/19020#19020
                      הרעיון הוא שאתה מגדיר שדה שהערך שלו יגדל ב1 על סמך שדה אחר בטבלה

                      PRIMARY KEY (SiteID,SiteWorkorderNum)
                      

                      והנה כל הדוגמא משם

                      mysql>     CREATE DATABASE david;
                      Query OK, 1 row affected (0.00 sec)
                      
                      mysql>     USE david
                      Database changed
                      mysql>     CREATE TABLE site_workorder_seq
                          ->     (
                          ->         SiteID int not null,
                          ->         SiteWorkorderNum int not null auto_increment,
                          ->         PRIMARY KEY (SiteID,SiteWorkorderNum)
                          ->     ) ENGINE=MyISAM;
                      Query OK, 0 rows affected (0.01 sec)
                      
                      mysql>     INSERT INTO site_workorder_seq (SiteID) VALUES
                          ->     (1),(1),(2),(3),(3),(3),(3),(4),(4),(4),
                          ->     (5),(5),(4),(2),(2),(2);
                      Query OK, 16 rows affected (0.00 sec)
                      Records: 16  Duplicates: 0  Warnings: 0
                      
                      mysql>     SELECT * FROM site_workorder_seq;
                      +--------+------------------+
                      | SiteID | SiteWorkorderNum |
                      +--------+------------------+
                      |      1 |                1 |
                      |      1 |                2 |
                      |      2 |                1 |
                      |      2 |                2 |
                      |      2 |                3 |
                      |      2 |                4 |
                      |      3 |                1 |
                      |      3 |                2 |
                      |      3 |                3 |
                      |      3 |                4 |
                      |      4 |                1 |
                      |      4 |                2 |
                      |      4 |                3 |
                      |      4 |                4 |
                      |      5 |                1 |
                      |      5 |                2 |
                      +--------+------------------+
                      16 rows in set (0.00 sec)
                      
                      

                      אין טסט כמו פרודקשן.

                      המייל שלי urivpn@gmail.com

                      yossizY תגובה 1 תגובה אחרונה
                      1
                      • clickoneC clickone

                        סליחה שאני שם כאן כ"כ הרבה מראי מקומות 😮
                        מאד תמוה בעצם שאין דבר כזה מובנה כי זה דבר די נפוץ מה שאתה מנסה לעשות
                        אבל ראיתי שזה קיים בmysql אבל רק עם המנוע MyISAM
                        https://dba.stackexchange.com/questions/19019/mysql-get-next-unique-value-without-auto-increment/19020#19020
                        הרעיון הוא שאתה מגדיר שדה שהערך שלו יגדל ב1 על סמך שדה אחר בטבלה

                        PRIMARY KEY (SiteID,SiteWorkorderNum)
                        

                        והנה כל הדוגמא משם

                        mysql>     CREATE DATABASE david;
                        Query OK, 1 row affected (0.00 sec)
                        
                        mysql>     USE david
                        Database changed
                        mysql>     CREATE TABLE site_workorder_seq
                            ->     (
                            ->         SiteID int not null,
                            ->         SiteWorkorderNum int not null auto_increment,
                            ->         PRIMARY KEY (SiteID,SiteWorkorderNum)
                            ->     ) ENGINE=MyISAM;
                        Query OK, 0 rows affected (0.01 sec)
                        
                        mysql>     INSERT INTO site_workorder_seq (SiteID) VALUES
                            ->     (1),(1),(2),(3),(3),(3),(3),(4),(4),(4),
                            ->     (5),(5),(4),(2),(2),(2);
                        Query OK, 16 rows affected (0.00 sec)
                        Records: 16  Duplicates: 0  Warnings: 0
                        
                        mysql>     SELECT * FROM site_workorder_seq;
                        +--------+------------------+
                        | SiteID | SiteWorkorderNum |
                        +--------+------------------+
                        |      1 |                1 |
                        |      1 |                2 |
                        |      2 |                1 |
                        |      2 |                2 |
                        |      2 |                3 |
                        |      2 |                4 |
                        |      3 |                1 |
                        |      3 |                2 |
                        |      3 |                3 |
                        |      3 |                4 |
                        |      4 |                1 |
                        |      4 |                2 |
                        |      4 |                3 |
                        |      4 |                4 |
                        |      5 |                1 |
                        |      5 |                2 |
                        +--------+------------------+
                        16 rows in set (0.00 sec)
                        
                        
                        yossizY מנותק
                        yossizY מנותק
                        yossiz
                        כתב ב נערך לאחרונה על ידי
                        #18

                        @clickone מעניין מאוד, זה בדיוק מה שחיפשתי (אבל זה לא קיים ב-postgres).

                        📧 יוסי@מייל.קום | 🌎 בלוג | ☕ קפה

                        clickoneC תגובה 1 תגובה אחרונה
                        2
                        • yossizY yossiz

                          @clickone מעניין מאוד, זה בדיוק מה שחיפשתי (אבל זה לא קיים ב-postgres).

                          clickoneC מנותק
                          clickoneC מנותק
                          clickone
                          כתב ב נערך לאחרונה על ידי
                          #19

                          @yossiz
                          כעת מצאתי משהו דומה על mssql
                          שזה יצירת אינדקס מותאם אישית, שעושה בדיוק את הפעולה הזו
                          https://stackoverflow.com/questions/12152790/sql-server-autoincrement-varying-by-value-of-another-field
                          עכשיו נשאר לבדוק האם יש אפשרות כזו גם בפוסטגרס, אם כי אולי תעדיף כבר להשאר עם הפיתרון הרגיל, שבכל מקרה זה מה שממומש מאחרי הקלעים....

                          אין טסט כמו פרודקשן.

                          המייל שלי urivpn@gmail.com

                          תגובה 1 תגובה אחרונה
                          2
                          • yossizY yossiz

                            @clickone עזוב טבלאות אחרות, בטעות הזכרתי שיש טבלה של org.
                            יש רק טבלה אחת של charges עם 3 עמודות (שקשורות לנושא שלנו): id, orgId, chargeNumber
                            ה-chargenumber אמור להיות מספר ה-charge לפי הארגון. זה לא יכול להיות autoincrement כי אפשר שתיים עם אותו מספר כאשר הם משוייכים לארגון אחר

                            chagoldC מנותק
                            chagoldC מנותק
                            chagold
                            כתב ב נערך לאחרונה על ידי
                            #20

                            @yossiz אמר במניעת race condition ב-DB:

                            @clickone עזוב טבלאות אחרות, בטעות הזכרתי שיש טבלה של org.
                            יש רק טבלה אחת של charges עם 3 עמודות (שקשורות לנושא שלנו): id, orgId, chargeNumber
                            ה-chargenumber אמור להיות מספר ה-charge לפי הארגון. זה לא יכול להיות autoincrement כי אפשר שתיים עם אותו מספר כאשר הם משוייכים לארגון אחר

                            לא שיש לי פתרון. אבל הרי הפרנציפ נמצא בכל טבלה עם מספור ID אוטומטי, רק שכאן אתה צריך לממש את זה ידנית, אבל מסתמא אפשר להעתיק את המימוש הזה משם?

                            yossizY תגובה 1 תגובה אחרונה
                            0
                            • A מנותק
                              A מנותק
                              avr416
                              כתב ב נערך לאחרונה על ידי avr416
                              #21

                              לא הבנתי למה לא נעילה ברמת הקוד?
                              גם את הנעילה הזאת אתה מקבל בחינם מהקוד..
                              ולגופו של ענין, הרי אתה לא ניגש לdb מחוץ לקוד, אז אני לא רואה סיבה למה לא להשתמש בזה.
                              אתה גם יכול לעשות נעילה בקוד פר ארגון, כך שלא יהיו לך הרבה התנגשויות.

                              אני מממש דבר כזה בחנות אינטרנטית, כשיש צורך להגביל מוצר לפי כמות במלאי, ואני לא רוצה שיווצר מצב דומה למה שתיארת.

                              תגובה 1 תגובה אחרונה
                              3
                              • chagoldC chagold

                                @yossiz אמר במניעת race condition ב-DB:

                                @clickone עזוב טבלאות אחרות, בטעות הזכרתי שיש טבלה של org.
                                יש רק טבלה אחת של charges עם 3 עמודות (שקשורות לנושא שלנו): id, orgId, chargeNumber
                                ה-chargenumber אמור להיות מספר ה-charge לפי הארגון. זה לא יכול להיות autoincrement כי אפשר שתיים עם אותו מספר כאשר הם משוייכים לארגון אחר

                                לא שיש לי פתרון. אבל הרי הפרנציפ נמצא בכל טבלה עם מספור ID אוטומטי, רק שכאן אתה צריך לממש את זה ידנית, אבל מסתמא אפשר להעתיק את המימוש הזה משם?

                                yossizY מנותק
                                yossizY מנותק
                                yossiz
                                כתב ב נערך לאחרונה על ידי yossiz
                                #22

                                @chagold אבל הקוד הפנימי של ה-DB שמממש את זה לא זמין לנו המשתמשים.

                                📧 יוסי@מייל.קום | 🌎 בלוג | ☕ קפה

                                chagoldC תגובה 1 תגובה אחרונה
                                0
                                • yossizY yossiz

                                  @chagold אבל הקוד הפנימי של ה-DB שמממש את זה לא זמין לנו המשתמשים.

                                  chagoldC מנותק
                                  chagoldC מנותק
                                  chagold
                                  כתב ב נערך לאחרונה על ידי
                                  #23

                                  @yossiz https://www.postgresql.org/docs/9.3/sourcerepo.html?

                                  yossizY תגובה 1 תגובה אחרונה
                                  0
                                  • chagoldC chagold

                                    @yossiz https://www.postgresql.org/docs/9.3/sourcerepo.html?

                                    yossizY מנותק
                                    yossizY מנותק
                                    yossiz
                                    כתב ב נערך לאחרונה על ידי
                                    #24

                                    @chagold אני יודע שקוד המקור של ה-DB זמין, אבל מה אני אעשה עם זה?
                                    אני לא הולך לערוך את הקוד ולקמפל כדי להוסיף אפשרות זו.

                                    📧 יוסי@מייל.קום | 🌎 בלוג | ☕ קפה

                                    תגובה 1 תגובה אחרונה
                                    3
                                    • chagoldC מנותק
                                      chagoldC מנותק
                                      chagold
                                      כתב ב נערך לאחרונה על ידי
                                      #25
                                      פוסט זה נמחק!
                                      תגובה 1 תגובה אחרונה
                                      0
                                      • yossizY yossiz

                                        יש לי טבלה של charges. כל charge משוייך ל-org על ידי עמודת orgId. אני אמור לתת לכל charge מספר. המספר הזה הוא לפי ארגון.
                                        היום כאשר אני מכניס שורה חדשה אני עושה ככה:

                                        1. מושך מה-DB את מספר ה-charge הגבוה ביותר של הארגון.
                                        2. מוסיף עליו 1.
                                        3. שומר charge חדש עם מספר המעודכן.

                                        עכשיו, ברור לכל שיש פה race condition אם מתווסף charge חדש לטבלה בין שלב 1 לשלב 3.

                                        יש לי כרגע 5 רעיונות איך לפתור את הבעיה. אשמח לשמוע את דעתכם. יצויין שמדובר ב-postgres, ואני משתמש ב-Sequelize ORM לכן יש עדיפות לפתרון שאפשר לממש ב-Sequelize.

                                        1. לעשות את התהליך בתוך טרנזקציה כאשר רמת הבידוד של הטרנזקציה הוא SERIALIZABLE. (רמת הבידוד ברירת המחדל לכאורה לא יפתור את הבעיה).
                                        2. לעשות נעילה על הטבלה לפני ביצוע שלב 1.
                                        3. לעשות עבור כל ארגון SEQUENCE ולקבל את מספר ה-charge הנוכחי מה-SEQUENCE.
                                        4. לעשות את כל התהליך בפקודת SQL אחד.
                                        5. לממש את הנעילה ברמת התוכנה בלי להזדקק לשירותי ה-DB.

                                        אני לא אוהב את פתרון 1 כי זה מסבך את הקוד, כי זה לא מונע בעיית מקביליות אלא מכשיל את הטרנזקציה כאשר יש בעיה ואז אני צריך לטפל בזה בקוד ולנסות שוב.
                                        לגבי פתרון 2, אני לא יודע עדיין על סוגי הנעילה שקיימים אבל ברור שאני רוצה נעילה הכי זולה. האם יש אפשרות לנעול רק הכנסת שורות חדשות עבור ארגון זו?
                                        פתרון 3 דורש עשיית טריגר או הוספת קוד לייצר SEQUENCE עובר כל ארגון חדש.
                                        פתרון 4, האם זה זהה ל-1 או ל-2? או שיש הבדלים?
                                        פתרון 5: אני לא אוהב את הרעיון של נעילה ברמת התוכנה כאשר אני מקבל את הנעילה בחינם מה-DB (אם רק הייתי יודע איך אני אמור לממש את זה) אבל אולי זה הפתרון הכי פשוט ונקי?

                                        אשמח לדעתכם.

                                        yossizY מנותק
                                        yossizY מנותק
                                        yossiz
                                        כתב ב נערך לאחרונה על ידי yossiz
                                        #26

                                        @yossiz אמר במניעת race condition ב-DB:

                                        1. לעשות את כל התהליך בפקודת SQL אחד.

                                        @dovid אמר במניעת race condition ב-DB:

                                        אני יודע שבSQL SERVER נכון להיום אתה מוגן ב4

                                        אתה בטוח בזה? יש לך מקור?

                                        @clickone אמר במניעת race condition ב-DB:

                                        לכאורה בשיטה הזו הוא ינעל את השינויים כי זה נעשה בפעם אחת

                                        מכיון שהנושא מאוד סקרן אותי והתחלתי לחשוש שזה לא נכון עשיתי נסיון,

                                        • יצרתי טבלה פשוטה:
                                        create table test (id  SERIAL, i INTEGER);
                                        

                                        ואז הרצתי בלולאה במקביל בשתי סשנים את הפקודה הזאת:

                                        INSERT INTO
                                            test (i)
                                        VALUES
                                            (
                                                (SELECT max FROM (SELECT MAX(i) AS max, pg_sleep(1) FROM test) AS i) + 1
                                            );
                                        

                                        (הוספתי את ה-pg_sleep כדי למקסם את הסיכויים להתנגשות)

                                        התוצאה היתה שהיו מספר שורות עם אותו מספר, בניגוד לצפיה שכל שורה תהיה מספר אחד מעל לשורה הקודמת, כלומר שהיה race condition.
                                        אח"כ שניתי את הפרמטרים של הקליינטים:

                                        SET default_transaction_isolation TO serializable;
                                        

                                        והרצתי את זה שוב, וחלק מהפעולות נכשלו בגלל התנגשויות

                                        לכאורה זה מלמד שרמת הבידוד בתוך פקודה בודדת שווה לרמת הבידוד של טרנזקציה - לא יותר. ואם כן אני לא מרוויח הרבה מפתרון 4 חוץ מזה שמשך הזמן שחשוף לבעיות התנגשות אולי יהיה קצת יותר קצר, אבל זה לא מגן לגמרי מהתנגשויות.

                                        אני חושש שזה המצב בכל המנועים ואם כן זו נקודה חשובה להיות מודע לזה.

                                        📧 יוסי@מייל.קום | 🌎 בלוג | ☕ קפה

                                        dovidD תגובה 1 תגובה אחרונה
                                        2
                                        • yossizY yossiz

                                          @yossiz אמר במניעת race condition ב-DB:

                                          1. לעשות את כל התהליך בפקודת SQL אחד.

                                          @dovid אמר במניעת race condition ב-DB:

                                          אני יודע שבSQL SERVER נכון להיום אתה מוגן ב4

                                          אתה בטוח בזה? יש לך מקור?

                                          @clickone אמר במניעת race condition ב-DB:

                                          לכאורה בשיטה הזו הוא ינעל את השינויים כי זה נעשה בפעם אחת

                                          מכיון שהנושא מאוד סקרן אותי והתחלתי לחשוש שזה לא נכון עשיתי נסיון,

                                          • יצרתי טבלה פשוטה:
                                          create table test (id  SERIAL, i INTEGER);
                                          

                                          ואז הרצתי בלולאה במקביל בשתי סשנים את הפקודה הזאת:

                                          INSERT INTO
                                              test (i)
                                          VALUES
                                              (
                                                  (SELECT max FROM (SELECT MAX(i) AS max, pg_sleep(1) FROM test) AS i) + 1
                                              );
                                          

                                          (הוספתי את ה-pg_sleep כדי למקסם את הסיכויים להתנגשות)

                                          התוצאה היתה שהיו מספר שורות עם אותו מספר, בניגוד לצפיה שכל שורה תהיה מספר אחד מעל לשורה הקודמת, כלומר שהיה race condition.
                                          אח"כ שניתי את הפרמטרים של הקליינטים:

                                          SET default_transaction_isolation TO serializable;
                                          

                                          והרצתי את זה שוב, וחלק מהפעולות נכשלו בגלל התנגשויות

                                          לכאורה זה מלמד שרמת הבידוד בתוך פקודה בודדת שווה לרמת הבידוד של טרנזקציה - לא יותר. ואם כן אני לא מרוויח הרבה מפתרון 4 חוץ מזה שמשך הזמן שחשוף לבעיות התנגשות אולי יהיה קצת יותר קצר, אבל זה לא מגן לגמרי מהתנגשויות.

                                          אני חושש שזה המצב בכל המנועים ואם כן זו נקודה חשובה להיות מודע לזה.

                                          dovidD מנותק
                                          dovidD מנותק
                                          dovid
                                          ניהול
                                          כתב ב נערך לאחרונה על ידי dovid
                                          #27

                                          @yossiz אמר במניעת race condition ב-DB:

                                          אתה בטוח בזה? יש לך מקור?

                                          כעת בדקתי, זה לא נכון (נוצר לי כפילות..) אז אני לא מחפש מקור 😞
                                          מהלינקים שהבאתי כבר למעלה עולה שחובה לעשות נעילה ברמת SERIALIZABLE בדיוק כפי שכתבת.
                                          יש פתרון פה לא הבנתי אותו, מריצים את זה באותו פקודה של ההכנסה?
                                          סתם ככה אשמח לדעת מה הרקע של הצורך.

                                          • מנטור אישי בתכנות והמסתעף – להתקדם לשלב הבא!
                                          • בכל נושא אפשר ליצור קשר dovid@tchumim.com
                                          yossizY 2 תגובות תגובה אחרונה
                                          2
                                          תגובה
                                          • תגובה כנושא
                                          התחברו כדי לפרסם תגובה
                                          • מהישן לחדש
                                          • מהחדש לישן
                                          • הכי הרבה הצבעות


                                          • 1
                                          • 2
                                          • 3
                                          בא תתחבר לדף היומי!
                                          • התחברות

                                          • אין לך חשבון עדיין? הרשמה

                                          • התחברו או הירשמו כדי לחפש.
                                          • פוסט ראשון
                                            פוסט אחרון
                                          0
                                          • דף הבית
                                          • קטגוריות
                                          • פוסטים אחרונים
                                          • משתמשים
                                          • חיפוש
                                          • חוקי הפורום