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