Tipp: Replikation, Change Data Capture, Client und Server-Paket im Überblick go-mysql bündelt MySQL-Funktionen in einer Go-Bibliothek

Anbieter zum Thema

FAST LTA GmbH

Impossible Cloud GmbH

Die Bibliothek go-mysql bildet das Wire-Protokoll von MySQL und MariaDB in reinem Go ab. Administratoren und Entwickler nutzen sie für Binlog-Replikation, Change Data Capture in Suchindizes, eigene MySQL-Proxys und einen alternativen database/sql-Treiber ohne Cgo-Abhängigkeit.

Das Open-Source-Projekt go-mysql bietet MySQL-spezifische Funktionen für Binlog-Parsing und Replikations-Streaming in Go-Anwendungen ohne C-Bindings. Die Codebasis folgt den Mindestanforderungen des Go-Compilers und unterstützt Linux unter den Architekturen amd64, s390x, arm64 und arm sowie FreeBSD amd64.

Replikation und Binlog-Streaming bilden die Grundfunktion

Das Replication-Paket schließt sich an einen MySQL-Master als Replica an und liefert die Binlog-Events an die eigene Anwendung. Die Konfiguration über „BinlogSyncerConfig“ legt eine eindeutige Server-ID, den Flavor (mysql oder mariadb), Host, Port und Zugangsdaten fest. Danach startet „StartSync“ an einer angegebenen Binlog-Datei und Position oder über „StartSyncGTID“ mit einem GTID-Set. Der zurückgegebene Streamer reicht Events vom Typ „RotateEvent“, „FormatDescriptionEvent“ und „QueryEvent“ an die Verarbeitung weiter. Die Dump-Methode gibt jedes Event in lesbarer Form aus, inklusive Position, Schema und ausgeführter SQL-Anweisung.

Für MariaDB steht der Parameter „FillZeroLogPos“ bereit. Die Option setzt das Flag „BINLOG_SEND_ANNOTATE_ROWS_EVENT“ und berechnet LogPos dynamisch für Events mit dem Wert null. Storage-Architekten mit Bedarf an LogPos-Verfolgung innerhalb von Transaktionen sichern sich damit eine verlässliche Positionsverfolgung trotz der MariaDB-Optimierung im Transaktions- und Statement-Cache.

Canal überträgt Datenbankänderungen in Suchindizes und Caches

Das Canal-Paket synchronisiert MySQL-Daten in nachgelagerte Systeme, darunter Redis und Elasticsearch. Zunächst legt Canal einen Dump der Ausgangsdaten an, danach folgt die inkrementelle Synchronisation über Binlog-Events. Voraussetzung ist das ROW-Format des Binlogs, vorzugsweise mit vollständigem Row-Image. Das minimale oder Noblob-Image führt bei Änderungen am Primärschlüssel zu Fehlern in der Synchronisation.

Eigene Event-Handler registrieren sich über das Interface „DummyEventHandler“ und reagieren in der Methode „OnRow“ auf eingehende Änderungen mit Action und betroffenen Datensätzen. Über „cfg.Dump.TableDB“ und „cfg.Dump.Tables“ lassen sich Datenbanken und Tabellen filtern, damit nur relevante Storage-Bereiche in die Pipeline gelangen.

Client mit Streaming und Connection Pool für lesende Last

Das Client-Paket stellt eine schlanke Verbindung zum MySQL-Server bereit. Die Methode „ExecuteSelectStreaming“ verarbeitet große SELECT-Ergebnisse zeilenweise über eine Callback-Funktion, ohne das gesamte Resultset im Speicher zu halten. Storage-relevante Bulk-Exports und ETL-Jobs profitieren von der Variante.

Der Connection Pool über „client.NewPool“ reicht vorgefertigte Verbindungen an parallele Worker durch. Anwender holen eine Verbindung über „GetConn“ und geben sie nach Gebrauch mit „PutConn“ zurück. Lesende Hochlast-Szenarien gegen MySQL-Storage bedienen sich damit bei gleichbleibend kurzen Antwortzeiten. Das Server-Paket implementiert die Server-Seite des MySQL-Protokolls und nimmt Pakete echter MySQL-Clients entgegen.

database/sql-Treiber als reine Go-Alternative

Der Driver integriert go-mysql in die Standard-Schnittstelle „database/sql“. Die DSN-Syntax folgt dem Muster „user:password@addr/db?param=X“ und unterstützt Parameter für Collation, Kompression mit zstd oder zlib, TLS-Modi, Lese- und Schreib-Time-outs sowie das Abschalten der Retry-Logik bei „ErrBadConn“. Entwickler nutzen alternativ die strukturierte Konfiguration über „sql.OpenDB“ mit einem „driver.Connector“ und übergeben Felder für Host, Benutzer und Datenbankname direkt als Struct.

Aktuelles E-Book

Storage-Software als Effizienzbooster

Mit der geeigneten Storage-Software kann sich ein Unternehmen einen Effizienzbooster ins Haus holen oder in der Cloud abonnieren. Dieser Booster steigert nicht nur die Performance der geschäftskritischen Anwendungen, sondern optimiert auch die Kosten der bereits installierten Speichersysteme.

Die Themen im Überblick:

• Herausforderungen eines modernen Speichersystems
• Methoden und Technologien effizienter Speichersysteme
• Effizienter Speicher mit Pure Storage, AWS, Cohesity und Dell

E-Book „Storage-Software als Effizienzbooster“ kostenlos downloaden

(ID:50878977)