首页 > 代码库 > JAVA JDBC 简单的增删改查
JAVA JDBC 简单的增删改查
package 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 简单的增删改查
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。