精华内容
下载资源
问答
  • JDBC增删改查

    2018-03-26 19:53:42
    JDBC增删改查 1.案例需求:jdbc增删改查 2.需要注意的:a.优化了注册驱动的步骤: //1.注册驱动com.mysql.jdbc.Driver DriverManager.registerDriver(new Driver()); 缺点:1.造成驱动被注册了两次  2.是...

    JDBC增删改查

    1.案例需求:jdbc增删改查
    2.需要注意的:a.优化了注册驱动的步骤:

    //1.注册驱动com.mysql.jdbc.Driver  
    DriverManager.registerDriver(new Driver());

    缺点:1.造成驱动被注册了两次
       2.是程序和驱动产生了紧耦合
    解决方法:Class.forName(“com.mysql.jdbc.Driver”); 
     
          b.传输器对象Statement
          作用:用来执行SQL
          提供的常用方法:
          executeQuery —执行查询的SQL
          executeUpdate — 执行增删改的SQL,返回int 类型

    package on.jdbc;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    import org.junit.Test;
    
    /**
     * 这个类用做jdbc的增删改查操作
     * 
     * @date 2018年3月23日
     *
     */
    public class JDBCCURD {
        Connection conn=null;
        Statement st=null;
        //需求:向account中插入一条记录
        //name为xiongda,money为2000
        @Test
        public void add(){
            try {
                //1.注册驱动
                Class.forName("com.mysql.jdbc.Driver");
                //2.获取数据库连接java.sql.Connection
                conn=DriverManager.getConnection("jdbc:mysql:///jt_db","root","root");
                //3.获取传输器java.sql.Statement
                st=conn.createStatement();
                String sql="insert into account values( null,'xiongda','2000')";
                //4.执行SQL语句
                int rows=st.executeUpdate(sql);//返回一个int
                //5.获取结果集
                System.out.println(rows);
            } catch (Exception e) {
    
                e.printStackTrace();
            }finally{
                //6.关闭资源
                if(conn!=null){
                    try {
                        conn.close();
                    } catch (SQLException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }finally{
                        conn=null;
                    }
                }
                if(st!=null){
                    try {
                        st.close();
                    } catch (SQLException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
            }
        }
        //需求:修改account表中
        //id为3的money为1000
        @Test
        public void update(){
            Connection conn=null;
            Statement st=null;
            try {
                //1.注册驱动
                Class.forName("com.mysql.jdbc.Driver");
                //2.获取数据库连接
                conn=DriverManager.getConnection("jdbc:mysql:///jt_db","root","root");
                //3.获取传输器
                st = conn.createStatement();//快捷键 Ctrl+1;
                //4.执行SQL
                String sql="update account set money=1000 where id=3";
                int rows=st.executeUpdate(sql);//返回一个int
                //5.获取查询结果集
                System.out.println(rows);
    
            } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }finally{
                //6.关闭资源
                if(conn!=null){
                    try{
                        conn.close();
                    }catch(SQLException e){
                        e.printStackTrace();
                    }finally{
                        conn=null;
                    }
                }
                if(st!=null){
                    try{
                        st.close();
                    }catch (SQLException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
            }
        }
        //需求:
        //删除account表中id为3的数据
        @Test
        public void delete(){
            Connection conn=null;
            Statement st=null;
            try {
                //1.注册驱动
                Class.forName("com.mysql.jdbc.Driver");
                //2.获取数据库的连接
                conn=DriverManager.getConnection("jdbc:mysql:///jt_db","root","root");
                //3.获取传输器
                st = conn.createStatement();    
                String sql="delete from account where id=3";
                //4.执行SQL
                int rows=st.executeUpdate(sql);
                //5.获取查询结果集
                System.out.println(rows);
    
            } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }finally{
                //6.关闭资源
                if(conn!=null){
                    try {
                        conn.close();
                    } catch (SQLException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }finally{
                        conn=null;
                    }
                }
                if(st!=null){
                    try {
                        st.close();
                    } catch (SQLException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }finally{
                        st=null;
                    }
                }
            }
        }
    
    }
    
    
    展开全文
  • JDBC 增删改查

    2018-05-08 15:08:00
    增删改查 1 package test03; 2 3 import java.sql.Connection; 4 import java.sql.DriverManager; 5 import java.sql.ResultSet; 6 import java.sql.Statement; 7 /** 8 * JDBC 增 ...

    增删改查

      1 package test03;
      2 
      3 import java.sql.Connection;
      4 import java.sql.DriverManager;
      5 import java.sql.ResultSet;
      6 import java.sql.Statement;
      7 /**
      8  * JDBC 增  
      9  *      删
     10  *      改
     11  *      查
     12  * @author star
     13  *
     14  */
     15 public class CURDTest {
     16     public static void main(String[] args) throws Exception {
     17         //insertTest();
     18         //deleteTest();
     19         //updateTest();
     20         selectTest();
     21     }
     22     //
     23     private static void selectTest() throws Exception {
     24         // TODO Auto-generated method stub
     25         //注册驱动
     26         Class.forName("com.mysql.jdbc.Driver");
     27         //创建连接
     28         Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day01", "root", "root");
     29         //创建Statement对象
     30         Statement st = conn.createStatement();
     31         //sql查询
     32         String sql = "select * from stu where math<80";
     33         ResultSet rs = st.executeQuery(sql);//结果集
     34         //显示
     35         while(rs.next()) {
     36             int id = rs.getInt(1);
     37             String name =rs.getString(2);
     38             int age = rs.getInt(3);
     39             int math = rs.getInt(4);
     40             int english = rs.getInt(5);
     41             System.out.println(id+" "+name+" "+age+" "+math+" "+english);
     42             
     43         }
     44         rs.close();
     45         st.close();
     46         conn.close();
     47         
     48         
     49     }
     50 
     51     //
     52     private static void updateTest() throws Exception {
     53         // TODO Auto-generated method stub
     54         //注册驱动
     55         
     56         Class.forName("com.mysql.jdbc.Driver");
     57         //建立连接
     58         Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day01", "root", "root");
     59         //创建statement对象
     60         Statement st = conn.createStatement();
     61         //执行sql语句
     62         String sql = "update stu set name = '小马哥' where id =1";
     63         int i = st.executeUpdate(sql);
     64         //判断是否修改
     65         if(i!=0) {
     66              System.out.println("修改成功");
     67         }
     68         //关闭资源
     69         st.close();
     70         conn.close();
     71         
     72     }
     73 
     74     //删除
     75     private static void deleteTest() throws Exception {
     76         // TODO Auto-generated method stub
     77         //注册驱动
     78         Class.forName("com.mysql.jdbc.Driver");
     79         //创建连接
     80         Connection conn = DriverManager.getConnection("jdbc:mysql://localhost/day01", "root", "root");
     81         //创建Statement对象
     82         Statement st = conn.createStatement();
     83         //  sql注入的问题
     84         //     在SQL语句中使用了系统自带的关键字 or and ,让where条件判断失效
     85         //String sql = "delete from stu where id= 1 or 1=1";//SQL注入问题,会把整张表的内容删除
     86         String sql = "delete from stu where id= 1";
     87         int i = st.executeUpdate(sql);
     88         if (i!=0) {
     89             System.out.println("删除成功");
     90         }
     91         st.close();
     92         conn.close();
     93     }
     94     //
     95     private static void insertTest() throws Exception {
     96         // TODO Auto-generated method stub
     97         //注册驱动
     98         Class.forName("com.mysql.jdbc.Driver");
     99         //创建连接
    100         Connection conn = DriverManager.getConnection("jdbc:mysql:///day01", "root", "root");
    101         //创建Statement对象
    102         Statement st = conn.createStatement();
    103         //执行语句
    104         String sql = "insert into stu values(null,'pp','50',70,50)";
    105         int i = st.executeUpdate(sql);
    106         //判断插入是否正确
    107         if (i!=0) {
    108             System.out.println("插入成功");
    109         }
    110         st.close();
    111         conn.close();
    112         
    113     }
    114 }
    增删改查

     

    jar包导入

    包: java.sql

      javax.sql

    1.加载驱动

    //DriverManager.registerDriver(new Driver());

    //通过源码发现Driver 类有一个静态代码块,自己创建一个对象添加进registerDriver(),我们自己又创建一个对象,造成两次注册
      //com.mysql.jdbc.Driver
      Class.forName("com.mysql.jdbc.Driver");

    //获取连接对象

    Connection coon = DriverManager.getConnection("jdbc:mysql://localhost:3306/day01","root","root");

    //获取statement对象

    Statement  st = coon.createStatement();

    //执行查询

    String sql = "select * from emp";

    ResultSet rs = st.executeQuery(sql);

    //获取结果集中的数据

    while(res.next()) {
       int id = res.getInt(1);
       String name = res.getString(2);
       String age = res.getString(3);
       int math = res.getInt(4);
       int english = res.getInt(5);
       System.out.println(id+" "+name +" "+age+" "+math+" "+english);
       
      }

     

    //释放资源

    rs.close();

    st.close();

    coon.close();

     1 package day28_test;
     2 
     3 
     4 import java.sql.Connection;
     5 import java.sql.DriverManager;
     6 import java.sql.ResultSet;
     7 import java.sql.SQLException;
     8 import java.sql.Statement;
     9 
    10 import com.mysql.jdbc.Driver;
    11 
    12 public class JDBC_Demo {
    13     public static void main(String[] args) throws Exception {
    14         //加载驱动
    15         DriverManager.registerDriver(new Driver());
    16         //获取连接对象
    17         Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day01", "root", "root");
    18         //获取Statement
    19         Statement st = conn.createStatement();
    20         //执行查询
    21         String sql = "select * from stu";
    22         ResultSet res = st.executeQuery(sql);
    23         //获取结果集中的数据
    24         while(res.next()) {
    25             int id = res.getInt(1);
    26             String name = res.getString(2);
    27             String age = res.getString(3);
    28             int math = res.getInt(4);
    29             int english = res.getInt(5);
    30             System.out.println(id+" "+name +" "+age+" "+math+" "+english);
    31             
    32         }
    33         //释放资源
    34         res.close();
    35         st.close();
    36         conn.close();
    37     }
    38 }
    JDBC

     

    转载于:https://www.cnblogs.com/star521/p/9008302.html

    展开全文
  • 主要介绍了JDBC增删改查和查唯一的完整代码解析,代码分为第四部分,每部分代码都不错,对jdbc增删改查操作感兴趣的朋友一起学习吧
  • jdbc增删改查

    2019-09-09 15:43:56
    //(update) String sql=“update stu set name=‘ccc’,age=19 where id=4”;// //String sql=“select * from stu”; //(Query) //4.得到statment对象 PreparedStatement statement = connection....

    在这里插入图片描述

    package com.zhongruan;

    import javax.naming.spi.DirectoryManager;
    import java.sql.*;

    public class test {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
    //1.加载驱动
    Class.forName(“com.mysql.jdbc.Driver”);
    //2.创建链接
    Connection connection=DriverManager.getConnection(“jdbc:mysql://localhost/zjgm?user=root&password=123456”);
    System.out.println(“创建连接成功”);
    //3.写sql
    //String sql=“insert into stu (name,age) value (‘zzp’,18)”;//增
    //String sql=“delete from stu where id=2”; //删(update)
    String sql=“update stu set name=‘ccc’,age=19 where id=4”;//改
    //String sql=“select * from stu”; //查(Query)
    //4.得到statment对象
    PreparedStatement statement = connection.prepareStatement(sql);
    //5.执行sql
    statement.executeUpdate();//query
    /*ResultSet resultSet = statement.executeQuery();
    //6.处理结果集
    while (resultSet.next()) {

                int id = resultSet.getInt(1);
               String name = resultSet.getString(2);
               int age = resultSet.getInt(3);
                System.out.println(id + name + age);
            }
            //7.关闭资源
        resultSet.close(); */
        statement.close();
        connection.close();
    }
    

    }

    展开全文
  • struts+jdbc增删改查

    2015-03-18 16:09:27
    struts+jdbc增删改查,,, struts2.0 一个小案例
  • 数据库 jdbc 增删改查

    2019-07-19 15:49:46
    jdbc 增删改查 //登录 相当于增删改查中的查 注册相当于增。 查 :executeQuery 方法。 增: 删: 改: sql语句,方法。 连接数据库方法。 import java.sql.Connection; import java.sql.DriverManager; import java...

    jdbc 增删改查
    //登录 相当于增删改查中的查
    注册相当于增。
    查 :executeQuery 方法。
    public Product findByName(String productName) {
    Product product=new Product();
    try {
    conn=jdbc.getConnection();
    String sql=“select * from product”;
    PreparedStatement st=conn.prepareStatement(sql);
    ResultSet rs=st.executeQuery();
    while (rs.next()) {
    product.setName(rs.getString(“name”));
    product.setOrderid(rs.getInt(“orderid”));
    product.setOrdertime(rs.getString(“ordertime”));
    product.setQuantity(rs.getInt(“quantity”));
    product.setTotalprice(rs.getDouble(“totalprice”));
    }
    rs.close();
    st.close();
    conn.close();
    }catch (ClassNotFoundException e) {
    e.printStackTrace();
    } catch (SQLException e) {
    e.printStackTrace();
    }
    return product;
    }
    //查询所有
    public ArrayList selectAll(){
    ArrayList productlist=new ArrayList();
    try {
    conn=jdbc.getConnection();
    String sql=“select * from product”;
    PreparedStatement st=conn.prepareStatement(sql);
    ResultSet rs=st.executeQuery();
    while (rs.next()) {
    Product product=new Product();
    product.setName(rs.getString(“name”));
    product.setOrderid(rs.getInt(“orderid”));
    product.setOrdertime(rs.getString(“ordertime”));
    product.setQuantity(rs.getInt(“quantity”));
    product.setTotalprice(rs.getDouble(“totalprice”));
    productlist.add(product);
    }
    rs.close();
    st.close();
    conn.close();
    }catch (ClassNotFoundException e) {
    e.printStackTrace();
    } catch (SQLException e) {
    e.printStackTrace();
    }
    return productlist;
    }
    增:JDBCComon jdbc=new JDBCComon();
    Connection conn=null;
    /**
    * 增加
    * @param product
    * @return
    */
    public boolean add(Product product){
    boolean flag=false;
    try {
    conn=jdbc.getConnection();
    String sql=“insert into product (name,category,price) values (?,?,?)”;
    PreparedStatement st=conn.prepareStatement(sql);
    st.setString(1, product.getName());
    st.setString(2, product.getCategory());
    st.setBigDecimal(3, product.getPrice());
    if(st.execute()){
    flag=true;
    }
    st.close();
    conn.close();
    } catch (ClassNotFoundException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
    } catch (SQLException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
    }
    return flag;
    };

    删: public boolean remove(int orderid) {
    boolean flag=false;
    try {
    conn=jdbc.getConnection();
    String sql=“delete from product where orderid=?”;
    PreparedStatement st=conn.prepareStatement(sql);
    st.setInt(1, orderid);
    if (st.execute()) {
    flag=true;
    }
    st.close();
    conn.close();
    }catch (ClassNotFoundException e) {
    e.printStackTrace();
    } catch (SQLException e) {
    e.printStackTrace();
    }
    return flag;
    改:public boolean update(Product product) {
    boolean flag=false;
    try {
    conn=jdbc.getConnection();
    String sql=“update product set name=?,ordertime=?,quantity=?,totalprice=? where orderid=?”;
    PreparedStatement st=conn.prepareStatement(sql);
    st.setString(1, product.getName());
    st.setString(2, product.getOrdertime());
    st.setInt(3, product.getQuantity());
    st.setDouble(4, product.getTotalprice());
    st.setInt(5, product.getOrderid());
    if (st.execute()) {
    flag=true;
    }
    st.close();
    conn.close();
    }catch (ClassNotFoundException e) {
    e.printStackTrace();
    } catch (SQLException e) {
    e.printStackTrace();
    }
    return flag;
    sql语句,方法。
    连接数据库方法。

    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.SQLException;

    public class JDBCComon {

    public Connection getConnection() throws ClassNotFoundException, SQLException{

    	Class.forName("com.mysql.cj.jdbc.Driver");
    	//java10是数据库的名字
    	String url="jdbc:mysql://localhost:3306/java10?useSSL=false&serverTimezone=UTC";
    	//登录数据库用户名
    	String username="root";
    	//登录数据库密码
    	String pwd="ymk677467";
    	Connection conn = DriverManager.getConnection(url,username,pwd);
    	return conn;
    

    运行测试
    ProductService ps=new ProductService();
    // 测试添加
    // Product p=new Product();
    // p.setOrdertime(“8点”);
    // p.setQuantity(2);
    // p.setName(“蒜香猪蹄饭”);
    // p.setTotalprice(38);
    // ps.add§;
    //测试删除

    // ps.remove(5);
    //查询
    // Product p1=ps.findByName(“黄焖鸡米饭”);
    // System.out.println(p1.getOrdertime());
    // System.out.println(p1.getName());
    // System.out.println(p1.getQuantity());
    // System.out.println(p1.getTotalprice());
    //修改
    // Product p1=new Product();
    // p1.setTotalprice(50);
    // ps.update(p1);
    ArrayList ls=ps.selectAll();
    for(int i=0;i<ls.size();i++){
    Product p2=(Product) ls.get(i);
    System.out.println(p2.getName());
    System.out.println(p2.getOrdertime());
    System.out.println(p2.getQuantity());
    System.out.println(p2.getTotalprice());
    System.out.println("--------------------");
    }

    }
    
    展开全文
  • 关于JDBC增删改查的方法 1.基础做法(较为繁琐) 2.运用DBUtil,加强了实际运用 3.简便的原理,如果用C3P0来简化代码(DBUtils的运用) 4.简便的代码 开始写JDBC的增删改查 我们开始写JDBC的增删改查的时候肯定是会...
  • JDBC增删改查学习笔记

    2020-12-03 20:49:48
    JDBC增删改查学习笔记 增删改查需要的步骤: 关联数据库驱动包(不同的数据库使用的驱动包是不一样的) 注册驱动(通过反射进行驱动的注册) 连接数据库获取数据库连接对象(登录-选择数据库的过程) 执行SQL语句 处理...
  • jdbc增删改查操作数据库

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 5,956
精华内容 2,382
关键字:

jdbc增删改查