package cdshop; import cdshop.CD; import java.sql.*; import java.util.ArrayList; import java.util.List; public class CdDao { private String baseSql = "select * from cdinfo where "; private String selectAllCdSql = "select * from cdinfo"; public List getCdList(String sql) { List<CD> cdList = new ArrayList(); return cdList; } public List getAllCdList() throws SQLException { List <CD> cdList = new ArrayList(); Connection conn = null; DBconn dbconn = new DBconn(); conn = dbconn.getConn(); String img = "./img/"; Statement stmt = null; if (conn != null) { stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery(selectAllCdSql); while (rs.next()) { CD tmp = new CD(); tmp.setCdId(rs.getString("cdId")); tmp.setCdName(rs.getString("cdName")); tmp.setCdArtist(rs.getString("cdArtist")); tmp.setCdCountry(rs.getString("cdCountry")); tmp.setCdType(rs.getString("cdType")); tmp.setCdDesc(rs.getString("cdDesc")); tmp.setCdSellDate(rs.getString("cdSellDate")); tmp.setCdStockNum(rs.getInt("cdStockNum")); tmp.setCdPrice(rs.getFloat("cdPrice")); tmp.setCdPicName(img + rs.getString("cdPicName")); tmp.setCdStatus(rs.getString("cdStatus")); cdList.add(tmp); } } return cdList; } }
db操作
insert 插入
// 数据库操作 DBConn dbConn = new DBConn(); Connection conn = dbConn.getConn(); String sqlStr = "INSERT INTO CdInfo VALUES (null,?,?,?,?,?,?,?,?,?,?)"; PreparedStatement ps = conn.prepareStatement(sqlStr); ps.setString(1, strName); ps.setString(2, strArtist); ps.setString(3, strCountry); ps.setString(4, strType); ps.setString(5, strDesc); ps.setDate(6, sellDate); ps.setFloat(7, cdprice); ps.setInt(8, stockNum); ps.setString(9, strPicName); ps.setString(10, "A"); int rs = ps.executeUpdate(); if ( rs <= 0 ) { System.out.println("Insert Error !"); // session.setAttribute("InsertOK", ""); } else { strActionResult = "CD数据插入成功!"; session.setAttribute("InsertOK", "CD数据插入成功!"); } ps.close(); conn.close(); }
catch(SQLException e){ e.printStackTrace(); }finally{ }
update更新
"UPDATE CdInfo SET ?,?,?,?,?,?,?,?,?,? WHERE cdid=" +oneCD.detCdId();
delete删除
try{ String sqlstr ="DELETE FROM CdInfo WHERE cdid="+cdID;" PreparedStatement ps=conn.prepareStatement(sqlStr); rs=ps.exeecuteUpdate(); if(rs<=0){ system.out.printlin("delete error!");
}