gh-ost/go/mysql/binlog_test.go

123 lines
3.7 KiB
Go
Raw Normal View History

2016-03-22 14:12:51 +00:00
/*
Copyright 2016 GitHub Inc.
2016-05-16 09:09:17 +00:00
See https://github.com/github/gh-ost/blob/master/LICENSE
2016-03-22 14:12:51 +00:00
*/
package mysql
2016-03-22 14:12:51 +00:00
import (
"testing"
"github.com/openark/golib/log"
test "github.com/openark/golib/tests"
2016-03-22 14:12:51 +00:00
)
func init() {
log.SetLevel(log.ERROR)
}
func TestBinlogCoordinates(t *testing.T) {
c1 := BinlogCoordinates{LogFile: "mysql-bin.00017", LogPos: 104}
c2 := BinlogCoordinates{LogFile: "mysql-bin.00017", LogPos: 104}
c3 := BinlogCoordinates{LogFile: "mysql-bin.00017", LogPos: 5000}
c4 := BinlogCoordinates{LogFile: "mysql-bin.00112", LogPos: 104}
test.S(t).ExpectTrue(c1.Equals(&c2))
test.S(t).ExpectFalse(c1.Equals(&c3))
test.S(t).ExpectFalse(c1.Equals(&c4))
test.S(t).ExpectFalse(c1.SmallerThan(&c2))
test.S(t).ExpectTrue(c1.SmallerThan(&c3))
test.S(t).ExpectTrue(c1.SmallerThan(&c4))
test.S(t).ExpectTrue(c3.SmallerThan(&c4))
test.S(t).ExpectFalse(c3.SmallerThan(&c2))
test.S(t).ExpectFalse(c4.SmallerThan(&c2))
test.S(t).ExpectFalse(c4.SmallerThan(&c3))
test.S(t).ExpectTrue(c1.SmallerThanOrEquals(&c2))
test.S(t).ExpectTrue(c1.SmallerThanOrEquals(&c3))
}
func TestBinlogNext(t *testing.T) {
c1 := BinlogCoordinates{LogFile: "mysql-bin.00017", LogPos: 104}
cres, err := c1.NextFileCoordinates()
test.S(t).ExpectNil(err)
test.S(t).ExpectEquals(c1.Type, cres.Type)
test.S(t).ExpectEquals(cres.LogFile, "mysql-bin.00018")
c2 := BinlogCoordinates{LogFile: "mysql-bin.00099", LogPos: 104}
cres, err = c2.NextFileCoordinates()
test.S(t).ExpectNil(err)
test.S(t).ExpectEquals(c1.Type, cres.Type)
test.S(t).ExpectEquals(cres.LogFile, "mysql-bin.00100")
c3 := BinlogCoordinates{LogFile: "mysql.00.prod.com.00099", LogPos: 104}
cres, err = c3.NextFileCoordinates()
test.S(t).ExpectNil(err)
test.S(t).ExpectEquals(c1.Type, cres.Type)
test.S(t).ExpectEquals(cres.LogFile, "mysql.00.prod.com.00100")
}
func TestBinlogPrevious(t *testing.T) {
c1 := BinlogCoordinates{LogFile: "mysql-bin.00017", LogPos: 104}
cres, err := c1.PreviousFileCoordinates()
test.S(t).ExpectNil(err)
test.S(t).ExpectEquals(c1.Type, cres.Type)
test.S(t).ExpectEquals(cres.LogFile, "mysql-bin.00016")
c2 := BinlogCoordinates{LogFile: "mysql-bin.00100", LogPos: 104}
cres, err = c2.PreviousFileCoordinates()
test.S(t).ExpectNil(err)
test.S(t).ExpectEquals(c1.Type, cres.Type)
test.S(t).ExpectEquals(cres.LogFile, "mysql-bin.00099")
c3 := BinlogCoordinates{LogFile: "mysql.00.prod.com.00100", LogPos: 104}
cres, err = c3.PreviousFileCoordinates()
test.S(t).ExpectNil(err)
test.S(t).ExpectEquals(c1.Type, cres.Type)
test.S(t).ExpectEquals(cres.LogFile, "mysql.00.prod.com.00099")
c4 := BinlogCoordinates{LogFile: "mysql.00.prod.com.00000", LogPos: 104}
_, err = c4.PreviousFileCoordinates()
test.S(t).ExpectNotNil(err)
}
func TestBinlogCoordinatesAsKey(t *testing.T) {
m := make(map[BinlogCoordinates]bool)
c1 := BinlogCoordinates{LogFile: "mysql-bin.00017", LogPos: 104}
c2 := BinlogCoordinates{LogFile: "mysql-bin.00022", LogPos: 104}
c3 := BinlogCoordinates{LogFile: "mysql-bin.00017", LogPos: 104}
c4 := BinlogCoordinates{LogFile: "mysql-bin.00017", LogPos: 222}
m[c1] = true
m[c2] = true
m[c3] = true
m[c4] = true
test.S(t).ExpectEquals(len(m), 3)
}
func TestBinlogFileNumber(t *testing.T) {
c1 := BinlogCoordinates{LogFile: "mysql-bin.00017", LogPos: 104}
c2 := BinlogCoordinates{LogFile: "mysql-bin.00022", LogPos: 104}
test.S(t).ExpectEquals(c1.FileNumberDistance(&c1), 0)
test.S(t).ExpectEquals(c1.FileNumberDistance(&c2), 5)
test.S(t).ExpectEquals(c2.FileNumberDistance(&c1), -5)
}
func TestBinlogFileNumberDistance(t *testing.T) {
c1 := BinlogCoordinates{LogFile: "mysql-bin.00017", LogPos: 104}
fileNum, numLen := c1.FileNumber()
test.S(t).ExpectEquals(fileNum, 17)
test.S(t).ExpectEquals(numLen, 5)
}