You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
64 lines
1.1 KiB
Go
64 lines
1.1 KiB
Go
package binlog
|
|
|
|
import (
|
|
"b612.me/mysql/gtid"
|
|
"encoding/binary"
|
|
"io"
|
|
"os"
|
|
)
|
|
|
|
func GetGtidOfBinlog(binlogPath string) (gtidDesc string, err error) {
|
|
file, err := os.Open(binlogPath)
|
|
if nil != err {
|
|
return "", err
|
|
}
|
|
defer file.Close()
|
|
|
|
p := uint32(4)
|
|
headerBs := make([]byte, 19)
|
|
gtidBs := make([]byte, 25)
|
|
myGtid, err := gtid.Parse(gtidDesc)
|
|
if err != nil {
|
|
return gtidDesc, err
|
|
}
|
|
for {
|
|
if _, err := file.Seek(int64(p), 0); nil != err {
|
|
if "EOF" == err.Error() {
|
|
break
|
|
}
|
|
return myGtid.String(), err
|
|
}
|
|
|
|
if _, err := io.ReadFull(file, headerBs); nil != err {
|
|
if "EOF" == err.Error() {
|
|
break
|
|
}
|
|
return myGtid.String(), err
|
|
}
|
|
|
|
length := binary.LittleEndian.Uint32(headerBs[9:13])
|
|
eventType := int(headerBs[4])
|
|
|
|
if GTID_LOG_EVENT != eventType {
|
|
p += length
|
|
continue
|
|
}
|
|
|
|
if _, err := io.ReadFull(file, gtidBs); nil != err {
|
|
if "EOF" == err.Error() {
|
|
break
|
|
}
|
|
return myGtid.String(), err
|
|
}
|
|
|
|
uuid := bytesToUuid(gtidBs[1:17])
|
|
number := bytesToUint64(gtidBs[17:])
|
|
if err = myGtid.AddGtid(uuid, number); nil != err {
|
|
return myGtid.String(), err
|
|
}
|
|
|
|
p += length
|
|
}
|
|
return myGtid.String(), nil
|
|
}
|