非常有用的jdbc操作数据库语句，记录下来，以方便以后的查询。 public class PersonDao { // 增加操作 public void insert(Person person) throws Exception; // 修改操作 public void update(Person person) throws Exception; // 删除操作 public void del
非常有用的jdbc操作数据库语句，记录下来，以方便以后的查询。
public class PersonDao { // 增加操作 public void insert(Person person) throws Exception; // 修改操作 public void update(Person person) throws Exception; // 删除操作 public void delete(String id) throws Exception ; // 按ID查询操作 public Person queryById(String id) throws Exception; // 查询全部 public List queryAll() throws Exception; // 模糊查询 public List queryByLike(String cond) throws Exception;}
// 此类需要完成具体的数据库操作，需要JDB代码 public class PersonDAOImpl implements PersonDAO { // 增加操作 public void insert(Person person) throws Exception { String sql = "INSERT INTO person (id,name,password,age,email) VALUES (?,?,?,?,?)" ; PreparedStatement pstmt = null ; DataBaseConnection dbc = null ; // 下面是针对数据库的具体操作 try { // 连接数据库 dbc = new DataBaseConnection() ; pstmt = dbc.getConnection().prepareStatement(sql) ; pstmt.setString(1,person.getId()) ; pstmt.setString(2,person.getName()) ; pstmt.setString(3,person.getPassword()) ; pstmt.setInt(4,person.getAge()) ; pstmt.setString(5,person.getEmail()) ; // 进行数据库更新操作 pstmt.executeUpdate() ; pstmt.close() ; } catch (Exception e) { throw new Exception("操作出现异常") ; } finally { // 关闭数据库连接 dbc.close() ; } } // 修改操作 public void update(Person person) throws Exception { String sql = "UPDATE person SET name=?,password=?,age=?,email=? WHERE id=?" ; PreparedStatement pstmt = null ; DataBaseConnection dbc = null ; // 下面是针对数据库的具体操作 try { // 连接数据库 dbc = new DataBaseConnection() ; pstmt = dbc.getConnection().prepareStatement(sql) ; pstmt.setString(1,person.getName()) ; pstmt.setString(2,person.getPassword()) ; pstmt.setInt(3,person.getAge()) ; pstmt.setString(4,person.getEmail()) ; pstmt.setString(5,person.getId()) ; // 进行数据库更新操作 pstmt.executeUpdate() ; pstmt.close() ; } catch (Exception e) { throw new Exception("操作出现异常") ; } finally { // 关闭数据库连接 dbc.close() ; } } // 删除操作 public void delete(String id) throws Exception { String sql = "DELETE FROM person WHERE id=?" ; PreparedStatement pstmt = null ; DataBaseConnection dbc = null ; // 下面是针对数据库的具体操作 try { // 连接数据库 dbc = new DataBaseConnection() ; pstmt = dbc.getConnection().prepareStatement(sql) ; pstmt.setString(1,id) ; // 进行数据库更新操作 pstmt.executeUpdate() ; pstmt.close() ; } catch (Exception e) { throw new Exception("操作出现异常") ; } finally { // 关闭数据库连接 dbc.close() ; } } // 按ID查询操作 public Person queryById(String id) throws Exception { Person person = null ; String sql = "SELECT id,name,password,age,email FROM person WHERE id=?" ; PreparedStatement pstmt = null ; DataBaseConnection dbc = null ; // 下面是针对数据库的具体操作 try { // 连接数据库 dbc = new DataBaseConnection() ; pstmt = dbc.getConnection().prepareStatement(sql) ; pstmt.setString(1,id) ; // 进行数据库查询操作 ResultSet rs = pstmt.executeQuery() ; if(rs.next()) { // 查询出内容，之后将查询出的内容赋值给person对象 person = new Person() ; person.setId(rs.getString(1)) ; person.setName(rs.getString(2)) ; person.setPassword(rs.getString(3)) ; person.setAge(rs.getInt(4)) ; person.setEmail(rs.getString(5)) ; } rs.close() ; pstmt.close() ; } catch (Exception e) { throw new Exception("操作出现异常") ; } finally { // 关闭数据库连接 dbc.close() ; } return person ; } // 查询全部 public List queryAll() throws Exception { List all = new ArrayList() ; String sql = "SELECT id,name,password,age,email FROM person" ; PreparedStatement pstmt = null ; DataBaseConnection dbc = null ; // 下面是针对数据库的具体操作 try { // 连接数据库 dbc = new DataBaseConnection() ; pstmt = dbc.getConnection().prepareStatement(sql) ; // 进行数据库查询操作 ResultSet rs = pstmt.executeQuery() ; while(rs.next()) { // 查询出内容，之后将查询出的内容赋值给person对象 Person person = new Person() ; person.setId(rs.getString(1)) ; person.setName(rs.getString(2)) ; person.setPassword(rs.getString(3)) ; person.setAge(rs.getInt(4)) ; person.setEmail(rs.getString(5)) ; // 将查询出来的数据加入到List对象之中 all.add(person) ; } rs.close() ; pstmt.close() ; } catch (Exception e) { throw new Exception("操作出现异常") ; } finally { // 关闭数据库连接 dbc.close() ; } return all ; } // 模糊查询 public List queryByLike(String cond) throws Exception { List all = new ArrayList() ; String sql = "SELECT id,name,password,age,email FROM person WHERE name LIKE ? or email LIKE ?" ; PreparedStatement pstmt = n<p>本文来源gao!%daima.com搞$代*!码9网(</p>ull ; DataBaseConnection dbc = null ; // 下面是针对数据库的具体操作 try { // 连接数据库 dbc = new DataBaseConnection() ; pstmt = dbc.getConnection().prepareStatement(sql) ; // 设置模糊查询条件 pstmt.setString(1,"%"+cond+"%") ; pstmt.setString(2,"%"+cond+"%") ; // 进行数据库查询操作 ResultSet rs = pstmt.executeQuery() ; while(rs.next()) { // 查询出内容，之后将查询出的内容赋值给person对象 Person person = new Person() ; person.setId(rs.getString(1)) ; person.setName(rs.getString(2)) ; person.setPassword(rs.getString(3)) ; person.setAge(rs.getInt(4)) ; person.setEmail(rs.getString(5)) ; // 将查询出来的数据加入到List对象之中 all.add(person) ; } rs.close() ; pstmt.close() ; } catch (Exception e) { throw new Exception("操作出现异常") ; } finally { // 关闭数据库连接 dbc.close() ; } return all ; } };
PS：
1.pstmt操作时，第一个空格处，应该填写1，而不是0，否则会报错误的列索引；
2.查询完resultSet以后，先要对其进行非空判断，如果存在，再进行下一步的赋值；
3.数据库每次连接时，都要记住关闭，当然完全可以用数据库连接池来取代它，后面会对此做改进。
搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：jdbc操作数据库语句
转载请注明原文链接：jdbc操作数据库语句
