H6A3JXrF

1import mysql.connector
2
3user = 'root';
4password = 'root';
5
6cnx = mysql.connector.connect(user=user, password=password,
7                              host='127.0.0.1',
8                              database='cs360')
9							  
10cursor = cnx.cursor();
11
12dropTable = "DROP TABLE IF EXISTS Employee";
13cursor.execute(dropTable);							  
14employee = "CREATE TABLE Employee (Id INT NOT NULL AUTO_INCREMENT,Name VARCHAR(200),Salary INT,DepartmentId INT,PRIMARY KEY (Id))";						  
15cursor.execute(employee);							  
16							  
17addEmployee = "INSERT INTO Employee (Name, Salary, DepartmentId) VALUES (%s, %s, %s)";							  
18dataEmployee = [('Joe', 70000, 1), ('Henry', 80000, 2)];			  
19cursor.executemany(addEmployee, dataEmployee);					  
20
21query = ("select * from Employee");
22cursor.execute(query);
23for (Id, Name, Salary, DepartmentId) in cursor:
24  print Id, Name, Salary, DepartmentId							  
25							  
26cnx.close()