java-mysql 使用druid连接池-增-删-改

记录 代码

增加数据

// 添加数据
    @Test
    public boolean testAdd() throws Exception {
        // 加载配置文件
        Properties prop = new Properties();
        prop.load(new FileInputStream("src/druid.properties"));

        //获取连接池对象
        DataSource dataSource = DruidDataSourceFactory.createDataSource(prop);

        // 获取数据库连接对象
        Connection conn = dataSource.getConnection();

        String sql = "insert into quange.tb_brand (brand_name, company_name, ordered, description, status) values" +
                " (?,?,?,?,?)";
        PreparedStatement preparedStatement = conn.prepareStatement(sql);
        preparedStatement.setString(1, "老坛涮菜");
        preparedStatement.setString(2, "老谭涮菜有限公司");
        preparedStatement.setInt(3, 20);
        preparedStatement.setString(4, "脚气老谭");
        preparedStatement.setInt(5, 1);

        // 执行mysql
        int i = preparedStatement.executeUpdate();
        if (i > 0) {
            System.out.println("添加数据成功");

            // 关闭链接
            preparedStatement.close();
            conn.close();

            return true;
        } else {
            System.out.println("添加失败!");
            return false;
        }
    }

修改数据

    // 修改数据
    @Test
    public void testUpdate() throws Exception {
        // 加载配置文件
        Properties prop = new Properties();
        prop.load(new FileInputStream("src/druid.properties"));

        //获取连接池对象
        DataSource dataSource = DruidDataSourceFactory.createDataSource(prop);

        // 获取数据库连接对象
        Connection conn = dataSource.getConnection();

        String sql = "update quange.tb_brand set brand_name=?,company_name=?,ordered=?,description=?,status=? where id =?";

        PreparedStatement preparedStatement = conn.prepareStatement(sql);
        preparedStatement.setString(1, "老谭");
        preparedStatement.setString(2, "老谭酸菜牛肉面");
        preparedStatement.setInt(3, 30);
        preparedStatement.setString(4, "牛肉面");
        preparedStatement.setInt(5, 1);
        preparedStatement.setInt(6, 4);

        int i = preparedStatement.executeUpdate();
        System.out.println(i > 0);

        // 关闭链接
        preparedStatement.close();
        conn.close();
    }

删除数据

    // 删除数据
    @Test
    public void testDel() throws Exception {
        // 加载配置文件
        Properties prop = new Properties();
        prop.load(new FileInputStream("src/druid.properties"));

        //获取连接池对象
        DataSource dataSource = DruidDataSourceFactory.createDataSource(prop);

        // 获取数据库连接对象
        Connection conn = dataSource.getConnection();

        String sql = "delete from tb_brand where id=?";
        PreparedStatement preparedStatement = conn.prepareStatement(sql);
        preparedStatement.setInt(1,4);

        int i = preparedStatement.executeUpdate();

        System.out.println(i > 0);

        // 关闭链接
        preparedStatement.close();
        conn.close();
    }
免责声明
本站提供的一切软件、教程和内容信息仅限用于学习和研究目的;不得将上述内容用于商业或者非法用途,否则,一切后果请用户自负。本站信息来自网络收集整理,版权争议与本站无关。您必须在下载后的24个小时之内,从您的电脑或手机中彻底删除上述内容。如果您喜欢该程序和内容,请支持正版,购买注册,得到更好的正版服务。我们非常重视版权问题,如有侵权请邮件与我们联系处理。敬请谅解!
THE END
分享
二维码
< <上一篇
下一篇>>