Morgenstern/sql-struktur.sql

-- Wechsel zur Datenbank 'engomo'
USE engomo;

-- Deklariere eine Tabellenvariable mit den Endungen der Tabellennamen
DECLARE @TableSuffixes TABLE (
    Suffix NVARCHAR(128)
);

-- Füge die gewünschten Tabellennamen-Endungen hinzu
INSERT INTO @TableSuffixes (Suffix) VALUES
    ('extras'),
    ('raeume'),
    ('badewanne'),
    ('toilette'),
    ('dusche'),
    ('waschbecken'),
    ('allgemein'),
    ('stammdaten'); -- Neue Tabelle ohne engomoid

-- Deklariere eine Tabellenvariable mit den Spalteninformationen
DECLARE @ColumnsToAdd TABLE (
    Suffix NVARCHAR(128),
    ColumnName NVARCHAR(128),
    ColumnType NVARCHAR(128)
);

-- Füge die gewünschten Spalten hinzu, einschließlich begehung_stammdaten ohne engomoid
INSERT INTO @ColumnsToAdd (Suffix, ColumnName, ColumnType) VALUES
    -- begehung_extras
    ('extras', 'engomoid', 'BIGINT NOT NULL'),
    ('extras', 'raum_bezeichnung', 'VARCHAR(255)'),
    ('extras', 'handtuchheizkoerper', 'BIT'),
    ('extras', 'badetuchhalter', 'BIT'),
    ('extras', 'waschmaschinenanschluss', 'BIT'),
    ('extras', 'notizen', 'TEXT'),

    -- begehung_raeume
    ('raeume', 'engomoid', 'BIGINT NOT NULL'),
    ('raeume', 'raumid', 'VARCHAR(255)'),
    ('raeume', 'raum_bezeichnung', 'VARCHAR(255)'),
    ('raeume', 'tapezieren', 'BIT'),
    ('raeume', 'anstrich_tuerblatt', 'BIT'),
    ('raeume', 'anstrich_tuerrahmen', 'BIT'),
    ('raeume', 'anstrich_tuerblatt_notizen', 'TEXT'),
    ('raeume', 'anstrich_heizkoerper', 'BIT'),
    ('raeume', 'anstrich_heizkoerper_notizen', 'TEXT'),
    ('raeume', 'anstrich_decke', 'BIT'),
    ('raeume', 'anstrich_decke_notizen', 'TEXT'),
    ('raeume', 'anstrich_waende', 'BIT'),
    ('raeume', 'anstrich_waende_notizen', 'TEXT'),
    ('raeume', 'anstrich_fenster', 'BIT'),
    ('raeume', 'anstrich_fenster_notizen', 'TEXT'),
    ('raeume', 'anstrich_fenstersims', 'BIT'),
    ('raeume', 'anstrich_fenstersims_notizen', 'TEXT'),
    ('raeume', 'material_fenster', 'VARCHAR(255)'),
    ('raeume', 'material_fenstersims', 'VARCHAR(255)'),
    ('raeume', 'material_bodenbelag', 'VARCHAR(255)'),
    ('raeume', 'sonstiges_einbauschrank', 'BIT'),
    ('raeume', 'sonstiges_einbauschrank_notizen', 'TEXT'),
    ('raeume', 'sonstiges_luefter', 'BIT'),
    ('raeume', 'sonstiges_luefter_notizen', 'TEXT'),
    ('raeume', 'notizen_verursachung_mieter', 'TEXT'),
    ('raeume', 'notizen_instandsetzung_mieter', 'TEXT'),
    ('raeume', 'notizen_instandsetzung_vermieter', 'TEXT'),

    -- begehung_badewanne
    ('badewanne', 'engomoid', 'BIGINT NOT NULL'),
    ('badewanne', 'raum_bezeichnung', 'VARCHAR(255)'),
    ('badewanne', 'ablauf_mit_stoepsel', 'BIT'),
    ('badewanne', 'excenter_garnitur', 'BIT'),
    ('badewanne', 'griff', 'BIT'),
    ('badewanne', 'handbrause_mit_schlauch', 'BIT'),

    -- begehung_dusche
    ('dusche', 'engomoid', 'BIGINT NOT NULL'),
    ('dusche', 'raum_bezeichnung', 'VARCHAR(255)'),
    ('dusche', 'ablagekorb', 'BIT'),
    ('dusche', 'duschabtrennung', 'BIT'),
    ('dusche', 'duschkabine', 'BIT'),
    ('dusche', 'duschstange', 'BIT'),
    ('dusche', 'duschstange_mit_seifenschale', 'BIT'),
    ('dusche', 'dusche_bodengleich', 'BIT'),
    ('dusche', 'duschtasse', 'BIT'),
    ('dusche', 'handbrause_mit_schlauch', 'BIT'),

    -- begehung_waschbecken
    ('waschbecken', 'engomoid', 'BIGINT NOT NULL'),
    ('waschbecken', 'raum_bezeichnung', 'VARCHAR(255)'),
    ('waschbecken', 'ablauf_mit_stoepsel', 'BIT'),
    ('waschbecken', 'doppelhandtuchhalter', 'BIT'),
    ('waschbecken', 'doppelwaschbecken', 'BIT'),
    ('waschbecken', 'doppelwaschtisch', 'BIT'),
    ('waschbecken', 'excenter_garnitur', 'BIT'),
    ('waschbecken', 'handtuchhalter', 'BIT'),
    ('waschbecken', 'handtuchhaken', 'BIT'),
    ('waschbecken', 'konsole', 'BIT'),
    ('waschbecken', 'seifenschale', 'BIT'),
    ('waschbecken', 'spiegelleuchte', 'BIT'),
    ('waschbecken', 'waschbecken', 'BIT'),

    -- begehung_toilette
    ('toilette', 'engomoid', 'BIGINT NOT NULL'),
    ('toilette', 'raum_bezeichnung', 'VARCHAR(255)'),
    ('toilette', 'sitz_mit_deckel', 'BIT'),
    ('toilette', 'sitz_mit_deckel_softclose', 'BIT'),
    ('toilette', 'toilettenpapierhalter', 'BIT'),

    -- begehung_stammdaten
    ('stammdaten', 'Vertrag', 'NVARCHAR(255)'),
    ('stammdaten', 'Wirtschaftseinheit', 'NVARCHAR(255)'),
    ('stammdaten', 'Mietobjekt', 'NVARCHAR(255)'),
    ('stammdaten', 'Strasse_und_Hausnummer', 'NVARCHAR(255)'),
    ('stammdaten', 'Postleitzahl', 'NVARCHAR(20)'),
    ('stammdaten', 'Ort', 'NVARCHAR(255)'),
    ('stammdaten', 'LeerstBeleg_ab', 'DATE'),
    ('stammdaten', 'Geschoss_Kurzbez', 'NVARCHAR(50)'),
    ('stammdaten', 'Lage_im_Geschoss', 'NVARCHAR(255)'),
    ('stammdaten', 'Anzahl_Raeume', 'INT'),
    ('stammdaten', 'Anzahl_halbe_Raeume', 'INT'),
    ('stammdaten', 'Hauptnutzflaeche', 'DECIMAL(18,2)'),
    ('stammdaten', 'Geschaeftspartner', 'NVARCHAR(255)'),
    ('stammdaten', 'Mietername', 'NVARCHAR(255)'),
    ('stammdaten', 'Name_weiterer_Mieter', 'NVARCHAR(255)');

-- Deklariere Variablen für die Tabellen-Schleife
DECLARE @CurrentSuffix NVARCHAR(128);
DECLARE @FullTableName NVARCHAR(256);
DECLARE @CreateTableColumns NVARCHAR(MAX);
DECLARE @SQL_CREATE NVARCHAR(MAX); -- Korrigierte Deklaration

-- Deklariere und öffne einen Cursor, um durch die Tabellennamen-Endungen zu iterieren
DECLARE table_cursor CURSOR FOR
    SELECT Suffix FROM @TableSuffixes;

OPEN table_cursor;

FETCH NEXT FROM table_cursor INTO @CurrentSuffix;

WHILE @@FETCH_STATUS = 0
BEGIN
    BEGIN TRY
        -- Erstelle den vollständigen Tabellennamen mit dem Präfix
        SET @FullTableName = 'begehung_' + @CurrentSuffix;

        -- Überprüfe, ob die Tabelle bereits existiert in der Datenbank 'engomo'
        IF NOT EXISTS (
            SELECT * 
            FROM INFORMATION_SCHEMA.TABLES 
            WHERE TABLE_NAME = @FullTableName
              AND TABLE_SCHEMA = 'dbo'
        )
        BEGIN
            -- Definiere das CREATE TABLE Statement basierend auf den erlaubten Spalten
            -- Die Spalteninformationen werden aus @ColumnsToAdd gefiltert

            SET @CreateTableColumns = (
                SELECT STRING_AGG('[' + ColumnName + '] ' + ColumnType, ', ')
                FROM @ColumnsToAdd
                WHERE Suffix = @CurrentSuffix
            );

            IF @CreateTableColumns IS NULL OR LEN(@CreateTableColumns) = 0
            BEGIN
                PRINT 'Keine Spalten definiert für Tabelle ' + @FullTableName + '. Tabelle wird nicht erstellt.';
            END
            ELSE
            BEGIN
                SET @SQL_CREATE = N'CREATE TABLE dbo.[' + @FullTableName + N'] (' + @CreateTableColumns + N');';

                -- Führe das dynamische SQL aus
                EXEC sp_executesql @SQL_CREATE;

                PRINT 'Tabelle ' + @FullTableName + ' wurde erstellt.';
            END
        END
        ELSE
        BEGIN
            PRINT 'Tabelle ' + @FullTableName + ' existiert bereits.';
        END
    END TRY
    BEGIN CATCH
        PRINT 'Fehler beim Erstellen der Tabelle ' + @FullTableName + ': ' + ERROR_MESSAGE();
    END CATCH

    -- Hole den nächsten Suffix
    FETCH NEXT FROM table_cursor INTO @CurrentSuffix;
END

-- Schließe und deallokiere den Cursor
CLOSE table_cursor;
DEALLOCATE table_cursor;

-- Füge den PRIMARY KEY für jede Tabelle hinzu, die engomoid hat
DECLARE @CurrentTable NVARCHAR(128);
DECLARE @PKName NVARCHAR(128);
DECLARE @AddPKSQL NVARCHAR(MAX);

DECLARE pk_cursor CURSOR FOR
    SELECT DISTINCT Suffix + '_engomoid' 
    FROM @ColumnsToAdd
    WHERE ColumnName = 'engomoid';

-- Alternative: Direkt die Tabellen, die 'engomoid' haben
DECLARE pk_cursor_correct CURSOR FOR
    SELECT DISTINCT 'begehung_' + Suffix
    FROM @ColumnsToAdd
    WHERE ColumnName = 'engomoid';

OPEN pk_cursor_correct;

FETCH NEXT FROM pk_cursor_correct INTO @CurrentTable;

WHILE @@FETCH_STATUS = 0
BEGIN
    BEGIN TRY
        -- Überprüfe, ob der PRIMARY KEY bereits existiert
        IF NOT EXISTS (
            SELECT * 
            FROM INFORMATION_SCHEMA.TABLE_CONSTRAINTS 
            WHERE TABLE_NAME = @CurrentTable
              AND CONSTRAINT_TYPE = 'PRIMARY KEY'
              AND TABLE_SCHEMA = 'dbo'
        )
        BEGIN
            -- Definiere den Constraint-Namen
            SET @PKName = 'PK_' + @CurrentTable;

            -- Definiere das ALTER TABLE Statement zum Hinzufügen des PRIMARY KEY
            SET @AddPKSQL = N'ALTER TABLE dbo.[' + @CurrentTable + N'] ADD CONSTRAINT [' + @PKName + N'] PRIMARY KEY (engomoid);';

            -- Führe das dynamische SQL aus
            EXEC sp_executesql @AddPKSQL;

            PRINT 'Primary Key auf engomoid in ' + @CurrentTable + ' wurde hinzugefügt.';
        END
        ELSE
        BEGIN
            PRINT 'Primary Key auf engomoid in ' + @CurrentTable + ' existiert bereits.';
        END
    END TRY
    BEGIN CATCH
        PRINT 'Fehler beim Hinzufügen des Primary Keys zu ' + @CurrentTable + ': ' + ERROR_MESSAGE();
    END CATCH

    -- Hole den nächsten TableName
    FETCH NEXT FROM pk_cursor_correct INTO @CurrentTable;
END

-- Schließe und deallokiere den Cursor
CLOSE pk_cursor_correct;
DEALLOCATE pk_cursor_correct;

-- Deklariere Variablen für die Spalten-Schleife
DECLARE @Suffix NVARCHAR(128);
DECLARE @TargetTableName NVARCHAR(128);
DECLARE @CurrentColumn NVARCHAR(128);
DECLARE @ColumnType NVARCHAR(128);
DECLARE @AddColumnSQL NVARCHAR(MAX);

-- Deklariere und öffne einen Cursor, um durch die Spalten zu iterieren
DECLARE column_cursor CURSOR FOR
    SELECT Suffix, ColumnName, ColumnType FROM @ColumnsToAdd;

OPEN column_cursor;

FETCH NEXT FROM column_cursor INTO @Suffix, @CurrentColumn, @ColumnType;

WHILE @@FETCH_STATUS = 0
BEGIN
    BEGIN TRY
        -- Rekonstruiere den vollständigen Tabellennamen
        SET @TargetTableName = 'begehung_' + @Suffix;

        -- Überprüfe, ob die Spalte bereits existiert
        IF NOT EXISTS (
            SELECT * 
            FROM INFORMATION_SCHEMA.COLUMNS 
            WHERE TABLE_NAME = @TargetTableName
              AND COLUMN_NAME = @CurrentColumn
              AND TABLE_SCHEMA = 'dbo'
        )
        BEGIN
            -- Definiere das ALTER TABLE Statement zum Hinzufügen der Spalte
            SET @AddColumnSQL = N'ALTER TABLE dbo.[' + @TargetTableName + N'] ADD [' + @CurrentColumn + N'] ' + @ColumnType + N';';

            -- Führe das dynamische SQL aus
            EXEC sp_executesql @AddColumnSQL;

            PRINT 'Spalte ' + @CurrentColumn + ' wurde zu ' + @TargetTableName + ' hinzugefügt.';
        END
        ELSE
        BEGIN
            PRINT 'Spalte ' + @CurrentColumn + ' existiert bereits in ' + @TargetTableName + '.';
        END
    END TRY
    BEGIN CATCH
        PRINT 'Fehler beim Hinzufügen der Spalte ' + @CurrentColumn + ' zu ' + @TargetTableName + ': ' + ERROR_MESSAGE();
    END CATCH

    -- Hole die nächste Spalte
    FETCH NEXT FROM column_cursor INTO @Suffix, @CurrentColumn, @ColumnType;
END

-- Schließe und deallokiere den Spalten-Cursor
CLOSE column_cursor;
DEALLOCATE column_cursor;

-- Deklariere Variablen für die Lösch-Schleife
DECLARE @ExistingColumnLoop NVARCHAR(128);
DECLARE @DeleteColumnSQL NVARCHAR(MAX);

-- Deklariere und öffne einen Cursor, um durch die Tabellen zu iterieren
DECLARE delete_cursor CURSOR FOR
    SELECT DISTINCT Suffix FROM @ColumnsToAdd;

OPEN delete_cursor;

FETCH NEXT FROM delete_cursor INTO @Suffix;

WHILE @@FETCH_STATUS = 0
BEGIN
    BEGIN TRY
        -- Rekonstruiere den vollständigen Tabellennamen
        SET @TargetTableName = 'begehung_' + @Suffix;

        -- Hole alle existierenden Spalten in der Tabelle
        DECLARE @ExistingColumns TABLE (ColumnName NVARCHAR(128));

        INSERT INTO @ExistingColumns (ColumnName)
        SELECT COLUMN_NAME
        FROM INFORMATION_SCHEMA.COLUMNS
        WHERE TABLE_NAME = @TargetTableName
          AND TABLE_SCHEMA = 'dbo';

        -- Iteriere durch jede existierende Spalte
        DECLARE ExistingColumnCursor CURSOR LOCAL FAST_FORWARD FOR
            SELECT ColumnName FROM @ExistingColumns;

        OPEN ExistingColumnCursor;

        FETCH NEXT FROM ExistingColumnCursor INTO @ExistingColumnLoop;

        WHILE @@FETCH_STATUS = 0
        BEGIN
            -- Überprüfe, ob die Spalte in den erlaubten Spalten ist
            IF NOT EXISTS (
                SELECT 1 
                FROM @ColumnsToAdd 
                WHERE Suffix = @Suffix
                  AND ColumnName = @ExistingColumnLoop
            )
            BEGIN
                BEGIN TRY
                    -- Definiere das ALTER TABLE Statement zum Löschen der Spalte
                    SET @DeleteColumnSQL = N'ALTER TABLE dbo.[' + @TargetTableName + N'] DROP COLUMN [' + @ExistingColumnLoop + N'];';

                    -- Führe das dynamische SQL aus
                    EXEC sp_executesql @DeleteColumnSQL;

                    PRINT 'Spalte ' + @ExistingColumnLoop + ' wurde aus ' + @TargetTableName + ' gelöscht.';
                END TRY
                BEGIN CATCH
                    -- Ignoriere den Fehler und fahre fort
                    PRINT 'Fehler beim Löschen der Spalte ' + @ExistingColumnLoop + ' aus ' + @TargetTableName + ': ' + ERROR_MESSAGE();
                END CATCH
            END
            ELSE
            BEGIN
                PRINT 'Spalte ' + @ExistingColumnLoop + ' ist erlaubt in ' + @TargetTableName + '.';
            END

            FETCH NEXT FROM ExistingColumnCursor INTO @ExistingColumnLoop;
        END

        -- Schließe und deallokiere den existierenden Spalten-Cursor
        CLOSE ExistingColumnCursor;
        DEALLOCATE ExistingColumnCursor;
    END TRY
    BEGIN CATCH
        PRINT 'Fehler beim Überprüfen/Löschen von Spalten in ' + @TargetTableName + ': ' + ERROR_MESSAGE();
    END CATCH

    -- Hole den nächsten Suffix
    FETCH NEXT FROM delete_cursor INTO @Suffix;
END

-- Schließe und deallokiere den Lösch-Cursor
CLOSE delete_cursor;
DEALLOCATE delete_cursor;