Browse Source

Merge pull request #593 from Zariel/more-schema-waiting

check schema consistency before creating tables
Chris Bannister 10 years ago
parent
commit
047b679538
1 changed files with 5 additions and 0 deletions
  1. 5 0
      common_test.go

+ 5 - 0
common_test.go

@@ -46,6 +46,11 @@ func addSslOptions(cluster *ClusterConfig) *ClusterConfig {
 var initOnce sync.Once
 var initOnce sync.Once
 
 
 func createTable(s *Session, table string) error {
 func createTable(s *Session, table string) error {
+	// lets just be really sure
+	if err := s.control.awaitSchemaAgreement(); err != nil {
+		return err
+	}
+
 	if err := s.control.query(table).Close(); err != nil {
 	if err := s.control.query(table).Close(); err != nil {
 		return err
 		return err
 	}
 	}