使用JDBC修改emp表各部门低于部门平均工资的员工的工资为当前工资加100元
时间: 2024-05-02 17:20:20 浏览: 129
以下是Java代码示例:
```java
import java.sql.*;
public class Main {
static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
static final String DB_URL = "jdbc:mysql://localhost/emp";
static final String USER = "username";
static final String PASS = "password";
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
try {
Class.forName(JDBC_DRIVER);
conn = DriverManager.getConnection(DB_URL, USER, PASS);
stmt = conn.createStatement();
// 查询各部门平均工资
String sql = "SELECT deptno, AVG(sal) AS avg_sal FROM emp GROUP BY deptno";
ResultSet rs = stmt.executeQuery(sql);
while (rs.next()) {
int deptno = rs.getInt("deptno");
double avg_sal = rs.getDouble("avg_sal");
// 更新低于部门平均工资的员工工资
String sql2 = "UPDATE emp SET sal = sal + 100 WHERE deptno = " + deptno + " AND sal < " + avg_sal;
int rows = stmt.executeUpdate(sql2);
System.out.println(rows + " rows updated for deptno " + deptno);
}
rs.close();
stmt.close();
conn.close();
} catch (SQLException se) {
se.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (stmt != null) stmt.close();
} catch (SQLException se2) {
}
try {
if (conn != null) conn.close();
} catch (SQLException se) {
se.printStackTrace();
}
}
}
}
```
说明:
1. 首先通过 JDBC 连接到 MySQL 数据库 emp。
2. 查询 emp 表中各部门的平均工资,使用 SQL GROUP BY 子句分组计算平均值。
3. 遍历查询结果,依次处理各部门的数据。
4. 对于每个部门,构建更新语句,使用 SQL WHERE 子句筛选出低于部门平均工资的员工,并将他们的工资加100元。
5. 执行更新语句,并输出更新的记录数。
6. 关闭数据库连接。
阅读全文