Rumah >pangkalan data >tutorial mysql >jdbc操作数据库语句
非常有用的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 = null ; 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.数据库每次连接时,都要记住关闭,当然完全可以用数据库连接池来取代它,后面会对此做改进。