当前访客身份:游客 [ 登录  | 注册加入尚学堂]
直播

我来了!

拥有积分:3868
尚学堂雄起!!威武。。。

博客分类

笔记中心

课题中心

提问中心

答题中心

解答题中心

jdbc操作数据库语句

我来了! 发表于 2年前 (2014-09-24 13:21:26)  |  评论(0)  |  阅读次数(443)| 5 人收藏此文章,   我要收藏   

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


分享到:0
关注微信,跟着我们扩展技术视野。每天推送IT新技术文章,每周聚焦一门新技术。微信二维码如下:
微信公众账号:尚学堂(微信号:bjsxt-java)
声明:博客文章版权属于原创作者,受法律保护。如果侵犯了您的权利,请联系管理员,我们将及时删除!
(邮箱:webmaster#sxt.cn(#换为@))
北京总部地址:北京市海淀区西三旗桥东建材城西路85号神州科技园B座三层尚学堂 咨询电话:400-009-1906 010-56233821
Copyright 2007-2015 北京尚学堂科技有限公司 京ICP备13018289号-1 京公网安备11010802015183