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 ; 
 } 
 }; 

1.pstmt操作时，第一个空格处，应该填写1，而不是0，否则会报错误的列索引；

2.查询完resultSet以后，先要对其进行非空判断，如果存在，再进行下一步的赋值；

3.数据库每次连接时，都要记住关闭，当然完全可以用数据库连接池来取代它，后面会对此做改进。