37
38
// CreateSchemaVersionTables sets up the schema version tables
40
>
return c.adminDb.CreateSchemaVersionTables()
41
>
}
42
43
// ReadSchemaVersion returns the current schema version for the keyspace
45
>
return c.adminDb.ReadSchemaVersion(c.dbName)
46
>
}
47
48
// UpdateSchemaVersion updates the schema version for the keyspace
49
>
func (c *Connection) UpdateSchemaVersion(newVersion string, minCompatibleVersion string) error {
conn.go
50
>
return c.adminDb.UpdateSchemaVersion(c.dbName, newVersion, minCompatibleVersion)
51
>
}
52
53
// WriteSchemaUpdateLog adds an entry to the schema update history table
54
>
func (c *Connection) WriteSchemaUpdateLog(oldVersion string, newVersion string, manifestMD5 string, desc string) error {
conn.go
55
>
return c.adminDb.WriteSchemaUpdateLog(oldVersion, newVersion, manifestMD5, desc)
56
>
}
57
58
// Exec executes a sql statement