JAVA JDBC 简单的增删改查
时间：2021-07-01 10:21:17
帮助过：15人阅读
jdbc_util;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class JdbcDemo {
// 设置汉字编码
String jdbcUrl = "jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8"
;
String className = "com.mysql.jdbc.Driver"
;
String user = "root"
;
String password = "920619"
;
public Connection getConnection() {
Connection connection =
null;
try {
// 加载数据库驱动
Class.forName(className);
// 获取数据库连接
connection =
DriverManager.getConnection(jdbcUrl, user, password);
} catch (Exception e) {
System.out.println("连接失败"
);
}
return connection;
}
public void closeConnection(Connection connection) {
try {
connection.close();
System.out.println("关闭成功"
);
} catch (SQLException e) {
System.out.println("关闭失败"
);
}
}
public void insert() {
String sql = "insert into user (UserName,PassWord,UserAge,UserSex) values(‘丙‘,‘123456‘, 20, 0)"
;
Connection connection =
getConnection();
try {
Statement statement =
connection.createStatement();
int result =
statement.executeUpdate(sql);
if (result != 0
) {
System.out.println("操作成功,受影响" + result + "行"
);
}
} catch (SQLException e) {
System.out.println("操作失败"
);
} finally {
closeConnection(connection);
}
}
public void delete() {
String sql = "delete from user where UserId in (2,3,4)"
;
Connection connection =
getConnection();
try {
Statement statement =
connection.createStatement();
int result =
statement.executeUpdate(sql);
if (result != 0
) {
System.out.println("操作成功,受影响" + result + "行"
);
}
} catch (SQLException e) {
System.out.println("操作失败"
);
} finally {
closeConnection(connection);
}
}
public void update() {
String sql = "update user set UserName = ‘乙‘ where UserId = 5"
;
Connection connection =
getConnection();
try {
Statement statement =
connection.createStatement();
int result =
statement.executeUpdate(sql);
if (result != 0
) {
System.out.println("操作成功,受影响" + result + "行"
);
}
} catch (SQLException e) {
System.out.println("操作失败"
);
} finally {
closeConnection(connection);
}
}
public void select() {
String sql = "select * from user"
;
Connection connection =
getConnection();
try {
Statement statement =
connection.createStatement();
ResultSet resultSet =
statement.executeQuery(sql);
while (resultSet.next()) {
System.out.println("UserName = " + resultSet.getString("UserName"
));
System.out.println("PassWord = " + resultSet.getString("PassWord"
));
System.out.println("UserAge = " + resultSet.getInt("UserAge"
));
String userSex = resultSet.getInt("UserSex") == 1 ? "男" : "女"
;
System.out.println("UserSex = " +
userSex);
}
} catch (SQLException e) {
System.out.println("操作失败"
);
} finally {
closeConnection(connection);
}
}
}
JAVA JDBC 简单的增删改查
标签：upd mysq val creat exception rman oca manage ==
