package Day30DBUtils;
import Day29_JDBC.JDBC_Util.JDBCUtilConfig;
import Day29_JDBC.JDBC_Util.JDBCUtils;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import java.sql.Connection;
import java.sql.SQLException;
/**
* @Author quzheng
* @Date 2019/10/3 23:36
* @Version 1.0
* 使用QueryRunner类实现 insert delete update
* 调用QueryRunner类的方法
* update(Connnection con,String sql,Object...param)
*
*/
public class QueryRunnerDemo {
private static Connection con = JDBCUtilConfig.getConnection();
public static void main(String[] args) throws SQLException {
// insert();
// update();
delete();
}
/**
*
* @throws SQLException
* QueryRunner()方法删除数据
*/
public static void delete() throws SQLException {
QueryRunner qr = new QueryRunner();
String sql = " delete from sort where sid=?";
int row = qr.update(con,sql,8);
System.out.println(row);
DbUtils.closeQuietly(con);
}
/**
*
* @throws SQLException
* 更新数据
*/
public static void update() throws SQLException {
QueryRunner qr = new QueryRunner();
String sql = " update sort set sname=?,sprice=?,sdesc=? where sid =?";
//定义Object数组,存储?中的参数
Object[] param = {"花卉",100.88,"情人节玫瑰",4};
int row = qr.update(con, sql,param);
System.out.println(row );
DbUtils.close(con);
}
/**
* 定义方法,使用update向数据库插入数据
*/
public static void insert() throws SQLException {
QueryRunner qr = new QueryRunner();
String sql = "insert into sort(sname,sprice,sdesc) values(?,?,?)";
Object[] params = {"体育用品",289.32,"购买体育用品"};
//调用QueryRunner类的update方法执行sql
int row = qr.update(JDBCUtilConfig.getConnection(),sql,params);
System.out.println(row);
DbUtils.close(con);
}
}
网友评论