jdbc连接mysql,利用preparedStatement实现增删改查
package com.examples.jdbc.o9_preparedStatement实现增删改;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.ResourceBundle;
/**
* preparedStatement实现jdbc增删改
*/
public class Test {
public static void main(String[] args) {
preparedStatement();
}
/**
* 利用preparedStatement实现jdbc增删改
*/
private static void preparedStatement(){
//资源绑定器绑定配置属性文件
ResourceBundle resourceBundle = ResourceBundle.getBundle("config/jdbc");
String driver = resourceBundle.getString("driver");
String url = resourceBundle.getString("url");
String userName = resourceBundle.getString("userName");
String passWord = resourceBundle.getString("passWord");
//2个资源对象
Connection connection = null;
PreparedStatement preparedStatement = null;
//jdbc6步骤
try {
//1.
Class.forName(driver);
//2.
connection = DriverManager.getConnection(url, userName, passWord);
//3.
//增
//String sql = "insert into tb_user (uname, upasswd) values(?, ?)";
//preparedStatement = connection.prepareStatement(sql);
//preparedStatement.setString(1, "wangxun");
//preparedStatement.setString(2, "coding");
//改
//String sql = "update tb_user set uname = ? where id = ?";
//preparedStatement = connection.prepareStatement(sql);
//preparedStatement.setString(1, "小涵");
//preparedStatement.setInt(2, 1);
//删
String sql = "delete from tb_user where uname = ?";
preparedStatement = connection.prepareStatement(sql);
preparedStatement.setString(1, "wangxun");
//4.
int num = preparedStatement.executeUpdate();
//System.out.println(num == 1 ? "插入成功" : "插入失败");
//System.out.println(num == 1 ? "修改成功" : "修改失败");
System.out.println(num == 1 ? "删除成功" : "删除失败");
} catch (ClassNotFoundException | SQLException e) {
e.printStackTrace();
}finally {
//6.
if(preparedStatement != null){
try {
preparedStatement.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(connection != null){
try {
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
}
相关文章
暂无评论...