הגירות מסד נתונים ליישומי אינטרנט

מיגרציות מסד נתונים ליישומי אינטרנט

אנו בונים מערכת מיגרציות למסד נתונים שמבטלת עריכות סכמה ידניות, שינויים שאבדו, וזמן השבתה בעת פריסה. במקום כאוס עם שאילתות ALTER בצ'אטים ותקלות עקב אי-התאמה בין קוד למסד נתונים—סקריפטים עם גרסאות, אימות אוטומטי ב-CI/CD, ועדכונים ללא זמן השבתה. מיגרציות אוטומטיות מקצרות את זמן אישור השינויים פי 5 בהשוואה לבקשות ידניות. הן גם משפרות את האמינות ומפחיתות תקלות באופן משמעותי. מיגרציות אוטומטיות אמינות פי 3 משינויי סכמה ידניים.

מדוע מיגרציות קריטיות לסביבת ייצור?

ללא מיגרציות, צוותים נתקלים לעיתים קרובות בסטיות סכמה בין סביבות, אובדן נתונים במהלך ALTER ידני, וחוסר יכולת לחזור לאחור במהירות. מערכת מיגרציות מוגדרת מבטיחה שמסד הנתונים תמיד תואם לקוד, ושינויים עוברים בדיקת קוד ובדיקות. מעל 90% מהתקלות הקשורות לנתונים נגרמות על ידי שינויי סכמה לא מאומתים—מיגרציות מבטלות זאת. עם הגדרה נכונה, מעל 95% מהמיגרציות מתבצעות ללא שגיאות. זמן החזרה לאחור הממוצע למיגרציה שנכשלה הוא כ-2 דקות.

כיצד לבחור את כלי המיגרציה המתאים?

בחירת הכלי תלויה בטכנולוגיה. אנו מעדיפים פתרונות אוניברסליים עם סקריפטים ב-SQL טהור, בלתי תלויים ב-ORM וניתנים להרצה מ-CI ללא הפעלת היישום. לדוגמה, Flyway תומך בכל טכנולוגיה ומאפשר מיגרציות משורת הפקודה ללא סביבת Java אם הסקריפטים כתובים ב-SQL.

עקרונות שאנו פועלים לפיהם:

• כל מיגרציה היא אטומית וניתנת לביטול (נדרש סקריפט down).
• מיגרציות בייצור לעולם לא נערכות—שגיאות מתוקנות עם מיגרציות חדשות.
• מיגרציות נתונים נפרדות ממיגרציות סכמה.

דוגמה עם golang-migrate

צור מיגרציה להוספת וקטור חיפוש:

migrate create -ext sql -dir db/migrations -seq add_search_vector_to_products 

-- 000003_add_search_vector_to_products.up.sql
BEGIN;
ALTER TABLE products ADD COLUMN IF NOT EXISTS search_vector TSVECTOR;
UPDATE products SET search_vector = to_tsvector('russian', coalesce(title, '') || ' ' || coalesce(description, ''));
CREATE INDEX CONCURRENTLY idx_products_search ON products USING GIN (search_vector);
CREATE OR REPLACE FUNCTION products_search_vector_update() RETURNS TRIGGER AS $$ BEGIN NEW.search_vector := to_tsvector('russian', coalesce(NEW.title, '') || ' ' || coalesce(NEW.description, '') ); RETURN NEW; END; $$ LANGUAGE plpgsql;
CREATE TRIGGER products_search_vector_trigger BEFORE INSERT OR UPDATE ON products FOR EACH ROW EXECUTE FUNCTION products_search_vector_update();
COMMIT;

-- 000003_add_search_vector_to_products.down.sql
BEGIN;
DROP TRIGGER IF EXISTS products_search_vector_trigger ON products;
DROP FUNCTION IF EXISTS products_search_vector_update();
DROP INDEX IF EXISTS idx_products_search;
ALTER TABLE products DROP COLUMN IF EXISTS search_vector;
COMMIT;

חשוב: לא ניתן להריץ את migrate create -ext sql -dir db/migrations -seq add_search_vector_to_products בתוך טרנזקציה. לפעולות כאלה, השתמש בשלב נפרד ללא -- 000003_add_search_vector_to_products.up.sql BEGIN; ALTER TABLE products ADD COLUMN IF NOT EXISTS search_vector TSVECTOR; UPDATE products SET search_vector = to_tsvector('russian', coalesce(title, '') || ' ' || coalesce(description, '')); CREATE INDEX CONCURRENTLY idx_products_search ON products USING GIN (search_vector); CREATE OR REPLACE FUNCTION products_search_vector_update() RETURNS TRIGGER AS $$ BEGIN NEW.search_vector := to_tsvector('russian', coalesce(NEW.title, '') || ' ' || coalesce(NEW.description, '') ); RETURN NEW; END; $$ LANGUAGE plpgsql; CREATE TRIGGER products_search_vector_trigger BEFORE INSERT OR UPDATE ON products FOR EACH ROW EXECUTE FUNCTION products_search_vector_update(); COMMIT; , או הגדר את Flyway עם -- 000003_add_search_vector_to_products.down.sql BEGIN; DROP TRIGGER IF EXISTS products_search_vector_trigger ON products; DROP FUNCTION IF EXISTS products_search_vector_update(); DROP INDEX IF EXISTS idx_products_search; ALTER TABLE products DROP COLUMN IF EXISTS search_vector; COMMIT; .

מיגרציות ללא זמן השבתה

כלל הזהב: כל מיגרציה חייבת להיות תואמת גם לגרסת הקוד הקודמת וגם לחדשה בו-זמנית. הפריסה נראית כך: המיגרציה מוחלת תחילה, לאחר מכן מועלות מופעים חדשים, והישנים מוסרים בהדרגה—שני הדורות רצים זה לצד זה.

-- Безопасно: NULL без DEFAULT
ALTER TABLE users ADD COLUMN phone VARCHAR(20);

-- Безопасно в PostgreSQL 11+: NOT NULL с DEFAULT (без перезаписи таблицы)
ALTER TABLE users ADD COLUMN is_verified BOOLEAN NOT NULL DEFAULT false;