使用jdbc实现增删改查示例

import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;import java.sql.Timestamp;import java.util.Date;import com.pb.news.util.ConfigManager;public class NewsDao {// 查询新闻信息public void getNewsList(){Connection connection=null;Statement stmt=null;ResultSet rs=null;String driver=ConfigManager.getInstance().getString("jdbc.driver_class");String url=ConfigManager.getInstance().getString("jdbc.connection.url");String username=ConfigManager.getInstance().getString("jdbc.connection.username");String password=ConfigManager.getInstance().getString("jdbc.connection.password");try {//（1）Class.forName()加载驱动Class.forName(driver);//（2）DriverManager.getConnection(URL,用户名,密码)获得数据库连接 (Connection)connection=DriverManager.getConnection(url,username,password);//（3）获得Statement对象，执行SQL语句String sql="select * from news_detail";stmt=connection.createStatement();rs=stmt.executeQuery(sql);//（4）处理执行结果(ResultSet)，while(rs.next()){int id=rs.getInt("id");String title=rs.getString("title");String summary=rs.getString("summary");String content=rs.getString("content");String author=rs.getString("author");Timestamp time=rs.getTimestamp("createdate");System.out.println(id + "\t" + title + "\t" + summary + "\t"+ content + "\t" + author + "\t" + time);}} catch (ClassNotFoundException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}finally{//释放资源try {rs.close();stmt.close();connection.close();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}// 增加新闻信息public void add(int id, int categoryId, String title, String summary,String content, Date createdate) {Connection connection=null;PreparedStatement pstmt=null;String driver=ConfigManager.getInstance().getString("jdbc.driver_class");String url=ConfigManager.getInstance().getString("jdbc.connection.url");String username=ConfigManager.getInstance().getString("jdbc.connection.username");String password=ConfigManager.getInstance().getString("jdbc.connection.password");try {//（1）Class.forName()加载驱动Class.forName(driver);//（2）DriverManager.getConnection(URL,用户名,密码)获得数据库连接 (Connection)connection=DriverManager.getConnection(url,username,password);//（3）获得Statement对象，执行SQL语句/*String sql="insert into news_detail(id,categoryId,title,summary,content,createdate) values("+id+","+categoryId+","+title+","+")";stmt=connection.createStatement();int i=stmt.executeUpdate(sql);*/String sql="insert into news_detail(id,categoryId,title,summary,content,createdate) values(?,?,?,?,?,?)";pstmt=connection.prepareStatement(sql);pstmt.setInt(1, id);pstmt.setInt(2, categoryId);pstmt.setString(3, title);pstmt.setString(4, summary);pstmt.setString(5, content);pstmt.setTimestamp(6, new java.sql.Timestamp(createdate.getTime()));int i=pstmt.executeUpdate();//（4）处理执行结果if(i>0){System.out.println("插入新闻成功！");}} catch (ClassNotFoundException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}finally{//释放资源try {pstmt.close();connection.close();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}//删除public void delete(int id) {Connection connection=null;PreparedStatement pstmt=null;String driver=ConfigManager.getInstance().getString("jdbc.driver_class");String url=ConfigManager.getInstance().getString("jdbc.connection.url");String username=ConfigManager.getInstance().getString("jdbc.connection.username");String password=ConfigManager.getInstance().getString("jdbc.connection.password");try {//（1）Class.forName()加载驱动Class.forName(driver);//（2）DriverManager.getConnection(URL,用户名,密码)获得数据库连接 (Connection)connection=DriverManager.getConnection(url,username,password);//（3）获得Statement对象，执行SQL语句/*String sql="insert into news_detail(id,categoryId,title,summary,content,createdate) values("+id+","+categoryId+","+title+","+")";stmt=connection.createStatement();int i=stmt.executeUpdate(sql);*/String sql="delete from news_detail where id=?";pstmt=connection.prepareStatement(sql);pstmt.setInt(1, id);int i=pstmt.executeUpdate();//（4）处理执行结果if(i>0){System.out.println("删除新闻成功！");}} catch (ClassNotFoundException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}finally{//释放资源try {pstmt.close();connection.close();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}//修改新闻信息public void update(int id, int categoryId, String title, String summary,String content, Date createdate,int oldid) {Connection connection=null;PreparedStatement pstmt=null;String driver=ConfigManager.getInstance().getString("jdbc.driver_class");String url=ConfigManager.getInstance().getString("jdbc.connection.url");String username=ConfigManager.getInstance().getString("jdbc.connection.username");String password=ConfigManager.getInstance().getString("jdbc.connection.password");try {//（1）Class.forName()加载驱动Class.forName(driver);//（2）DriverManager.getConnection(URL,用户名,密码)获得数据库连接 (Connection)connection=DriverManager.getConnection(url,username,password);//（3）获得Statement对象，执行SQL语句/*String sql="insert into news_detail(id,categoryId,title,summary,content,createdate) values("+id+","+categoryId+","+title+","+")";stmt=connection.createStatement();int i=stmt.executeUpdate(sql);*/String sql="update news_detail set id=?,categoryId=?,title=?,summary=?,content=?,createDate=? where id=?";pstmt=connection.prepareStatement(sql);pstmt.setInt(1, id);pstmt.setInt(2, categoryId);pstmt.setString(3, title);pstmt.setString(4, summary);pstmt.setString(5, content);pstmt.setTimestamp(6, new java.sql.Timestamp(createdate.getTime()));pstmt.setInt(7, oldid);int i=pstmt.executeUpdate();//（4）处理执行结果if(i>0){System.out.println("修改新闻成功！");}} catch (ClassNotFoundException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}finally{//释放资源try {pstmt.close();connection.close();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}//测试public static void main(String[] args) {NewsDao newsDao=new NewsDao();        newsDao.add(3, 1, "快女选秀快讯", "快女比赛正进入白热化", "她、她、她，谁是你心中的快女冠军？",new Date());//newsDao.delete(3);newsDao.update(2, 1, "快女选秀快讯", "快女比赛正进入白热化", "她、她、她，谁是你心中的快女冠军？",new Date(),3);newsDao.getNewsList();}}