Migration von anderen Treibern zu go-mssqldb

Dieser Leitfaden hilft Go-Entwicklern dabei, von PostgreSQL, MySQL und anderen Datenbanktreibern auf SQL Server zu go-mssqldb migrieren. Es behandelt SQL-Syntaxunterschiede, treiberspezifische Änderungen und entsprechende Muster für gängige Operationen.

Warum mit go-mssqldb auf SQL Server migrieren

Checkliste für Migrationsüberlegungen

Überprüfen Sie diese Punkte, bevor Sie mit der Portierung von Abfragen beginnen, Zeile für Zeile:

Für ausführlichere Hinweise zu diesen Bereichen siehe Abfragen und Statements, Einschränkungen, Datentyp-Mappings, Microsoft Entra ID-Authentifizierung und Fehlerbehebung.

Von lib/pq (PostgreSQL) migrieren

Ändern Sie den Import und den Treibernamen

Ersetzen Sie den Import und den lib/pq Treibernamen durch go-mssqldb:

import _ "github.com/lib/pq"
db, err := sql.Open("postgres", connString)

// After (SQL Server with go-mssqldb):
import _ "github.com/microsoft/go-mssqldb"
db, err := sql.Open("sqlserver", connString)

Ändern Sie das Format des Verbindungszeichenfolge

Konvertiere das PostgreSQL-Schlüssel-Wert-Format in eine SQL Server-URL:

// lib/pq connection string:
"host=<server> port=5432 user=<user> password=<password> dbname=AdventureWorks2025 sslmode=require"

// go-mssqldb connection string:
"sqlserver://<user>:<password>@<server>:1433?database=AdventureWorks2025&encrypt=true"

Parameteränderungs-Platzhalter

PostgreSQL verwendet $1, $2 positionsbezogene Platzhalter. SQL Server verwendet benannte Parameter mit @:

// PostgreSQL (lib/pq):
db.QueryContext(ctx, "SELECT * FROM users WHERE id = $1 AND status = $2", id, status)

// SQL Server (go-mssqldb):
db.QueryContext(ctx, "SELECT ProductID, Name FROM Production.Product WHERE ProductID = @id AND Color = @color",
    sql.Named("id", id),
    sql.Named("color", color))

Änderungen der SQL-Syntax

Eingefügte ID abrufen

Ersetzen Sie die RETURNING Klausel von PostgreSQL durch die OUTPUT Klausel von SQL Server:

var id int
err := db.QueryRowContext(ctx,
    "INSERT INTO users (name, email) VALUES ($1, $2) RETURNING id",
    name, email).Scan(&id)

// SQL Server (go-mssqldb) using OUTPUT:
var id int
err := db.QueryRowContext(ctx,
    "INSERT INTO HumanResources.Department (Name, GroupName) OUTPUT INSERTED.DepartmentID VALUES (@name, @groupName)",
    sql.Named("name", name),
    sql.Named("groupName", groupName)).Scan(&id)

Paginierung

Ersetzen Sie die Syntax LIMIT/OFFSET durch die Syntax OFFSET/FETCH NEXT.

// PostgreSQL:
"SELECT * FROM employees ORDER BY id LIMIT $1 OFFSET $2"

// SQL Server (requires ORDER BY):
"SELECT ProductID, Name, ListPrice FROM Production.Product ORDER BY ProductID OFFSET @offset ROWS FETCH NEXT @limit ROWS ONLY"

Migration von pgx (PostgreSQL)

Der Treiber pgx verwendet seinen eigenen Verbindungspool und eine eigene API, die sich von database/sqlunterscheiden. Um zu migrieren, wechsel auf die Standard-Schnittstelle database/sql .

Wechsel vom PGX-Pool zu Datenbank/SQL

Ersetzen Sie die pgxpool API durch die Standard-Schnittstelle database/sql .

// Before (pgx):
import "github.com/jackc/pgx/v5/pgxpool"
pool, err := pgxpool.New(ctx, "postgres://user:pass@<server>:5432/AdventureWorks2025")
defer pool.Close()
rows, err := pool.Query(ctx, "SELECT * FROM users WHERE id = $1", id)

// After (go-mssqldb with database/sql):
import (
    "database/sql"
    _ "github.com/microsoft/go-mssqldb"
)
db, err := sql.Open("sqlserver", "sqlserver://user:pass@<server>:1433?database=AdventureWorks2025")
defer db.Close()
rows, err := db.QueryContext(ctx,
    "SELECT ProductID, Name FROM Production.Product WHERE ProductID = @id", sql.Named("id", id))

Ersetzen Sie pgx-spezifische Funktionen

Von go-sql-driver/mysql (MySQL) migrieren

Vertausche den MySQL-Import- und Treibernamen

Ersetzen Sie den MySQL-Import- und Treibernamen durch go-mssqldb.

// Before (MySQL):
import _ "github.com/go-sql-driver/mysql"
db, err := sql.Open("mysql", connString)

// After (SQL Server):
import _ "github.com/microsoft/go-mssqldb"
db, err := sql.Open("sqlserver", connString)

Konvertiere das MySQL DSN-Format

Konvertiere das MySQL-DSN-Format in eine SQL Server-URL.

// MySQL DSN:
"user:password@tcp(<server>:3306)/AdventureWorks2025?tls=true"

// go-mssqldb URL:
"sqlserver://user:password@<server>:1433?database=AdventureWorks2025&encrypt=true"

Fragezeichen-Platzhalter ersetzen

MySQL verwendet ? positionsbezogene Platzhalter.

// MySQL:
db.QueryContext(ctx, "SELECT * FROM users WHERE id = ? AND status = ?", id, status)

// SQL Server:
db.QueryContext(ctx, "SELECT ProductID, Name FROM Production.Product WHERE ProductID = @id AND Color = @color",
    sql.Named("id", id),
    sql.Named("color", color))

Vergleich der Syntax von MySQL und SQL Server

Ersetzen Sie MySQL-spezifische Syntax

AUTO_INCREMENT auf IDENTITY:

-- MySQL:
CREATE TABLE users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(100)
);

-- SQL Server:
CREATE TABLE HumanResources.NewDepartment (
    DepartmentID SMALLINT IDENTITY(1,1) PRIMARY KEY,
    Name NVARCHAR(50) NOT NULL
);

LIMIT zum OFFSET/FETCH:

-- MySQL:
SELECT * FROM users LIMIT 10 OFFSET 20;

-- SQL Server:
SELECT ProductID, Name, ListPrice
FROM Production.Product
ORDER BY ProductID
OFFSET 20 ROWS FETCH NEXT 10 ROWS ONLY;

Allgemeine Migrationsmuster

Zuletzt eingefügte ID abrufen

Verwenden Sie die OUTPUT Klausel oder SCOPE_IDENTITY() um den Identitätswert der eingefügten Zeile abzurufen:

// Pattern 1: OUTPUT clause (recommended, works with batch inserts).
var id int64
err := db.QueryRowContext(ctx,
    "INSERT INTO HumanResources.Department (Name, GroupName) OUTPUT INSERTED.DepartmentID VALUES (@name, @groupName)",
    sql.Named("name", "Engineering"),
    sql.Named("groupName", "Research and Development")).Scan(&id)

// Pattern 2: SCOPE_IDENTITY (works with single-row inserts).
var id int64
err := db.QueryRowContext(ctx,
    "INSERT INTO HumanResources.Department (Name, GroupName) VALUES (@name, @groupName); SELECT SCOPE_IDENTITY()",
    sql.Named("name", "Engineering"),
    sql.Named("groupName", "Research and Development")).Scan(&id)

Upsert (Einfügen oder Aktualisieren)

Die ON CONFLICT von PostgreSQL und die ON DUPLICATE KEY UPDATE von MySQL entsprechen den MERGE von SQL Server:

_, err := db.ExecContext(ctx, `
    MERGE HumanResources.Department AS target
    USING (SELECT @id AS DepartmentID, @name AS Name, @groupName AS GroupName) AS source
    ON target.DepartmentID = source.DepartmentID
    WHEN MATCHED THEN
        UPDATE SET Name = source.Name, GroupName = source.GroupName, ModifiedDate = GETDATE()
    WHEN NOT MATCHED THEN
        INSERT (Name, GroupName, ModifiedDate) VALUES (source.Name, source.GroupName, GETDATE());`,
    sql.Named("id", dept.ID),
    sql.Named("name", dept.Name),
    sql.Named("groupName", dept.GroupName))

Masseneinfügung

Ersetzen Sie PostgreSQL COPY oder MySQL LOAD DATA durch mssql.CopyIn.

import mssql "github.com/microsoft/go-mssqldb"

stmt, err := db.Prepare(mssql.CopyIn("HumanResources.Department", mssql.BulkOptions{}, "Name", "GroupName", "ModifiedDate"))
if err != nil {
    return err
}

for _, dept := range departments {
    _, err = stmt.Exec(dept.Name, dept.GroupName, time.Now())
    if err != nil {
        return err
    }
}

// Flush the buffer.
_, err = stmt.Exec()
if err != nil {
    return err
}
stmt.Close()

Handle NULL-Werte

Alle Go-Datenbanktreiber handhaben NULL-Werte gleich, weil sie die Typen database/sql verwenden.

var color sql.NullString
err := db.QueryRowContext(ctx,
    "SELECT Color FROM Production.Product WHERE ProductID = @id",
    sql.Named("id", 1)).Scan(&color)

if color.Valid {
    fmt.Println(color.String)
} else {
    fmt.Println("NULL")
}

Transaktionen

Alle Go-Datenbanktreiber verwenden dieselbe database/sql Transaktions-API.

tx, err := db.BeginTx(ctx, nil)
if err != nil {
    return err
}
defer tx.Rollback()

_, err = tx.ExecContext(ctx,
    "UPDATE Production.ProductInventory SET Quantity = Quantity - @qty WHERE ProductID = @pid AND LocationID = @fromLoc",
    sql.Named("qty", qty),
    sql.Named("pid", productID),
    sql.Named("fromLoc", fromLocationID))
if err != nil {
    return err
}

_, err = tx.ExecContext(ctx,
    "UPDATE Production.ProductInventory SET Quantity = Quantity + @qty WHERE ProductID = @pid AND LocationID = @toLoc",
    sql.Named("qty", qty),
    sql.Named("pid", productID),
    sql.Named("toLoc", toLocationID))
if err != nil {
    return err
}

return tx.Commit()

Migrationscheckliste

Verwandte Inhalte

• Quickstart
• Installation
• Verbindungszeichenfolgen
• Datentypzuordnungen
• Massenaktionen
• Tabellenwertparameter