用Java语句创建MySQL的订单表、用户表、管理员表和价格表,并连接数据库,触发器,进行增删改查
时间: 2024-01-20 08:04:41 浏览: 132
好的,我会尽力回答您的问题。首先,您需要安装Java的MySQL驱动程序,然后使用以下代码创建订单表、用户表、管理员表和价格表,并连接数据库:
```java
import java.sql.*;
public class MySQLExample {
// MySQL连接信息
static final String DB_URL = "jdbc:mysql://localhost/mydatabase";
static final String USER = "username";
static final String PASS = "password";
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
try {
// 注册JDBC驱动程序
Class.forName("com.mysql.jdbc.Driver");
// 打开连接
System.out.println("连接数据库...");
conn = DriverManager.getConnection(DB_URL, USER, PASS);
// 创建订单表
System.out.println("创建订单表...");
stmt = conn.createStatement();
String sql = "CREATE TABLE Orders " +
"(OrderID INT PRIMARY KEY NOT NULL AUTO_INCREMENT, " +
" CustomerID INT NOT NULL, " +
" OrderDate DATE NOT NULL, " +
" ShipDate DATE, " +
" FOREIGN KEY (CustomerID) REFERENCES Customers(CustomerID))";
stmt.executeUpdate(sql);
// 创建用户表
System.out.println("创建用户表...");
sql = "CREATE TABLE Customers " +
"(CustomerID INT PRIMARY KEY NOT NULL AUTO_INCREMENT, " +
" FirstName VARCHAR(255) NOT NULL, " +
" LastName VARCHAR(255) NOT NULL, " +
" Email VARCHAR(255) NOT NULL UNIQUE, " +
" Password VARCHAR(255) NOT NULL)";
stmt.executeUpdate(sql);
// 创建管理员表
System.out.println("创建管理员表...");
sql = "CREATE TABLE Admins " +
"(AdminID INT PRIMARY KEY NOT NULL AUTO_INCREMENT, " +
" FirstName VARCHAR(255) NOT NULL, " +
" LastName VARCHAR(255) NOT NULL, " +
" Email VARCHAR(255) NOT NULL UNIQUE, " +
" Password VARCHAR(255) NOT NULL)";
stmt.executeUpdate(sql);
// 创建价格表
System.out.println("创建价格表...");
sql = "CREATE TABLE Prices " +
"(PriceID INT PRIMARY KEY NOT NULL AUTO_INCREMENT, " +
" ProductID INT NOT NULL, " +
" Price DECIMAL(10,2) NOT NULL, " +
" FOREIGN KEY (ProductID) REFERENCES Products(ProductID))";
stmt.executeUpdate(sql);
System.out.println("所有表创建成功!");
} catch (SQLException se) {
// 处理JDBC错误
se.printStackTrace();
} catch (Exception e) {
// 处理Class.forName错误
e.printStackTrace();
} finally {
// 关闭资源
try {
if (stmt != null) stmt.close();
} catch (SQLException se2) {
} // 什么都不做
try {
if (conn != null) conn.close();
} catch (SQLException se) {
se.printStackTrace();
}
}
}
}
```
以上代码将创建一个名为"mydatabase"的MySQL数据库,并在其中创建名为"Orders"、"Customers"、"Admins"和"Prices"的表。
接下来,您可以使用Java代码来添加、删除、更新和查询表中的数据,例如:
```java
import java.sql.*;
public class MySQLExample {
// MySQL连接信息
static final String DB_URL = "jdbc:mysql://localhost/mydatabase";
static final String USER = "username";
static final String PASS = "password";
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
try {
// 注册JDBC驱动程序
Class.forName("com.mysql.jdbc.Driver");
// 打开连接
System.out.println("连接数据库...");
conn = DriverManager.getConnection(DB_URL, USER, PASS);
// 添加数据到订单表
System.out.println("添加数据到订单表...");
stmt = conn.createStatement();
String sql = "INSERT INTO Orders (CustomerID, OrderDate, ShipDate) " +
"VALUES (1, '2021-01-01', '2021-01-05')";
stmt.executeUpdate(sql);
// 更新数据到用户表
System.out.println("更新数据到用户表...");
sql = "UPDATE Customers SET FirstName='John' WHERE CustomerID=1";
stmt.executeUpdate(sql);
// 删除数据从管理员表
System.out.println("删除数据从管理员表...");
sql = "DELETE FROM Admins WHERE AdminID=1";
stmt.executeUpdate(sql);
// 查询数据从价格表
System.out.println("查询数据从价格表...");
sql = "SELECT Price FROM Prices WHERE ProductID=1";
ResultSet rs = stmt.executeQuery(sql);
while (rs.next()) {
double price = rs.getDouble("Price");
System.out.println("价格: " + price);
}
rs.close();
} catch (SQLException se) {
// 处理JDBC错误
se.printStackTrace();
} catch (Exception e) {
// 处理Class.forName错误
e.printStackTrace();
} finally {
// 关闭资源
try {
if (stmt != null) stmt.close();
} catch (SQLException se2) {
} // 什么都不做
try {
if (conn != null) conn.close();
} catch (SQLException se) {
se.printStackTrace();
}
}
}
}
```
以上代码将添加一条订单记录、更新一个用户的名字、删除一个管理员的记录,并查询一个产品的价格。
最后,您可以使用MySQL的触发器来在表上设置自动化操作。例如,以下代码将创建一个触发器,用于在订单表中插入新记录时更新相关用户的最后订购日期:
```java
import java.sql.*;
public class MySQLExample {
// MySQL连接信息
static final String DB_URL = "jdbc:mysql://localhost/mydatabase";
static final String USER = "username";
static final String PASS = "password";
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
try {
// 注册JDBC驱动程序
Class.forName("com.mysql.jdbc.Driver");
// 打开连接
System.out.println("连接数据库...");
conn = DriverManager.getConnection(DB_URL, USER, PASS);
// 创建触发器
System.out.println("创建触发器...");
stmt = conn.createStatement();
String sql = "CREATE TRIGGER UpdateLastOrder " +
"AFTER INSERT ON Orders " +
"FOR EACH ROW " +
"UPDATE Customers " +
"SET LastOrderDate=NEW.OrderDate " +
"WHERE CustomerID=NEW.CustomerID";
stmt.executeUpdate(sql);
System.out.println("触发器创建成功!");
} catch (SQLException se) {
// 处理JDBC错误
se.printStackTrace();
} catch (Exception e) {
// 处理Class.forName错误
e.printStackTrace();
} finally {
// 关闭资源
try {
if (stmt != null) stmt.close();
} catch (SQLException se2) {
} // 什么都不做
try {
if (conn != null) conn.close();
} catch (SQLException se) {
se.printStackTrace();
}
}
}
}
```
以上代码将创建一个名为"UpdateLastOrder"的触发器,用于在订单表中插入新记录时更新相关用户的最后订购日期。
希望这些代码能够帮助您开始使用Java连接MySQL数据库并进行增删改查和触发器操作。
阅读全文