~lifeless/storm/bug-620615

« back to all changes in this revision

Viewing changes to tests/store/mysql.py

Merging fixes from James.

Show diffs side-by-side

added added

removed removed

Lines of Context:
43
43
        self.database = create_database(os.environ["STORM_MYSQL_URI"])
44
44
 
45
45
    def create_tables(self):
46
 
        connection = self.database.connect()
 
46
        connection = self.connection
47
47
        connection.execute("CREATE TABLE foo "
48
48
                           "(id INT PRIMARY KEY AUTO_INCREMENT,"
49
49
                           " title VARCHAR(50) DEFAULT 'Default Title') "
91
91
        self.database = create_database(os.environ["STORM_MYSQL_URI"])
92
92
 
93
93
    def create_tables(self):
94
 
        connection = self.database.connect()
95
 
        connection.execute("CREATE TABLE foo "
96
 
                           "(id INT PRIMARY KEY AUTO_INCREMENT,"
97
 
                           " title VARCHAR(50) DEFAULT 'Default Title') "
98
 
                           "ENGINE=InnoDB")
99
 
        connection.commit()
 
94
        self.connection.execute("CREATE TABLE foo "
 
95
                                "(id INT PRIMARY KEY AUTO_INCREMENT,"
 
96
                                " title VARCHAR(50) DEFAULT 'Default Title') "
 
97
                                "ENGINE=InnoDB")
 
98
        self.connection.commit()