使用jdbc实现增删改查示例
2012-08-28 18:19
781 查看
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 block e.printStackTrace(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ //释放资源 try { rs.close(); stmt.close(); connection.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.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 block e.printStackTrace(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ //释放资源 try { pstmt.close(); connection.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.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 block e.printStackTrace(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ //释放资源 try { pstmt.close(); connection.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.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 block e.printStackTrace(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ //释放资源 try { pstmt.close(); connection.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.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(); } }
相关文章推荐
- 使用PHP连接数据库_实现用户数据的增删改查的整体操作示例
- PHP程序中使用PDO对象实现对数据库的增删改查操作的示例代码
- PHP程序中使用PDO对象实现对数据库的增删改查操作的示例代码
- Android开发(10)使用SQLiteDatabase操作SQLite数据库实现增删改查(源码)
- Hibernate中JPA的简单使用,实现简单的对表的增删改查操作
- JDBC 实现 含参的增删改查操作
- JDBC 实现通用的增删改查基础类方法
- SpringMVC(17):使用springmvc+spring+jdbc 优化订单管理系统的示例(新增用户的功能实现)
- angularJs实现增删改查示例2-JS文件
- 一个使用Pro*C实现增删改查的小例子
- JAVA 利用JDBC连接MYSQL数据库以及增删改查的实现【学习笔记】
- 使用存储过程操作数据库(实现增删改查)
- Springboot+hibernate实现简单的增删改查示例
- 使用 Dojo 和 Grails 快速实现数据的增删改查(CRUD)
- 使用springmvc+mybatis实现增删改查并进行登录注册功能
- SpringMVC(18):使用springmvc+spring+jdbc 优化订单管理系统的示例(供应商新增的功能实现)
- 使用JDBC实现数据访问对象层(DAO)代码示例
- 使用DbUtils实现增删改查——ResultSetHandler接口的实现类
- SpringMVC(16):使用springmvc+spring+jdbc 优化订单管理系统的示例(多条件查询供应商列表功能实现)
- 使用python对xml文件实现增删改查的简单封装