Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import mysql.connector
- SCHEMA_PATH = 'mysql_schema.sql'
- mysql_conn = mysql.connector.connect(
- user='X',
- password='X',
- host='X')
- mysql_cursor = mysql_conn.cursor()
- with open(SCHEMA_PATH, 'rt') as f:
- schema = f.read()
- mysql_cursor.execute(schema,multi=True)
- mysql_conn.close()
- CREATE DATABASE `X`;
- USE `X`;
- CREATE TABLE `profile` (
- `id` int(11) AUTO_INCREMENT,
- `birth_date` date,
- `first_name` varchar(30),
- `last_name` varchar(30),
- `phone_number1` varchar(30),
- `phone_number2` varchar(30),
- `address_id` int(11) REFERENCES `address`(`id`),
- PRIMARY KEY (`id`),
- )ENGINE=InnoDB;
- CREATE TABLE `address` (
- `id` int(11) AUTO_INCREMENT,
- `line1` varchar(100) DEFAULT '',
- `street` varchar(100) DEFAULT '',
- `suburb` varchar(100) DEFAULT '',
- `postcode` varchar(100) DEFAULT '',
- `state` varchar(100) DEFAULT '',
- `country` varchar(100) DEFAULT 'Australia',
- PRIMARY KEY (`id`),
- )ENGINE=InnoDB;
- quit
- try:
- mysql_cursor.execute(schema)
- except Exception:
- mysql_cursor.execute(schema,multi=True)
Add Comment
Please, Sign In to add comment