Java对数据库操作增删改查

Java对数据库操作增删改查

SQL新增数据

//SQL新增数据
    public static void zengSQL() {
        //private static final String URL="jdbc:mysql://localhost:3306/数据库名";//jdbc:mysql//服务器地址/数据库名
        //private static final String USER="用户名";//用户名
        //private static final String PASSWORD="密码";//密码
        try {
            //1.加载驱动程序 此语句固定,使用MySQL数据库无需更改,在JSP中可不加异常处理
            //Class.forName("com.mysql.jdbc.Driver");

            //2.建立数据库的连接
            Connection con = DriverManager.getConnection(URL,USER,PASSWORD);

            //3.通过数据库的连接操作数据库,实现新增数据
            Statement sql = con.createStatement();
            String new_member = "insert into sqls(sql1,sql2,sql3) values('表单值1','表单值2','表单值3')";

            //一次增加多条数据
            //String new_member="insert into 表名(表单名1,表单名2)"
            //new_menber += "values('表单值1','表单值2'),";
            //new_menber += "('表单值1','表单值2')";

            //4.执行发送
            sql.executeUpdate(new_member);
            con.close();//断开数据库连接
        }
        catch(SQLException E) {
            System.out.println("SQL异常!!!!");
            System.out.println(E); //打印异常
        }
    }

SQL查找数据

//SQL查找数据
    public static void chaSQL() {
        //private static final String URL="jdbc:mysql://localhost:3306/数据库名";//jdbc:mysql//服务器地址/数据库名
        //private static final String USER="用户名";//用户名
        //private static final String PASSWORD="密码";//密码
        try {
            //1.加载驱动程序 此语句固定,使用MySQL数据库无需更改,在JSP中可不加异常处理
            //Class.forName("com.mysql.jdbc.Driver");

            //2.建立数据库的连接
            Connection con = DriverManager.getConnection(URL,USER,PASSWORD);

            //3.通过数据库的连接操作数据库,实现查找数据
            Statement sql = con.createStatement();

            //4.执行发送
            ResultSet rs = sql.executeQuery("select * from sqls");

            //5.打印数据表结果
            while (rs.next()) {
                System.out.println(rs.getString("sql1"));//表单名,即表头//数据库设计时,表头使用英文
            }

            con.close();//断开数据库连接
        }
        catch(SQLException E) {
            System.out.println("SQL异常!!!!");
            System.out.println(E); //打印异常
        }
    }

SQL修改数据

//SQL修改数据
    public static void gaiSQL() {
        //private static final String URL="jdbc:mysql://localhost:3306/数据库名";//jdbc:mysql//服务器地址/数据库名
        //private static final String USER="用户名";//用户名
        //private static final String PASSWORD="密码";//密码
        try {
            //1.加载驱动程序 此语句固定,使用MySQL数据库无需更改,在JSP中可不加异常处理
            //Class.forName("com.mysql.jdbc.Driver");

            //2.建立数据库的连接
            Connection con = DriverManager.getConnection(URL,USER,PASSWORD);

            //3.通过数据库的连接操作数据库
            Statement sql = con.createStatement();
           // String new_member = "update sqls set sql1='表单值123',sql2='表单值2345' where sql2=10";
            String new_member = "update sqls set sql1='表单值123',sql2='表单值2345'";
            //name='qjh' where id=1;

            //4.发送执行
            sql.executeUpdate(new_member);

            con.close();//断开数据库连接
        }
        catch(SQLException E) {
            System.out.println("SQL异常!!!!");
            System.out.println(E); //打印异常
        }
    }

SQL删除数据

//SQL删除数据
    public static void shanSQL() {
        //private static final String URL="jdbc:mysql://localhost:3306/数据库名";//jdbc:mysql//服务器地址/数据库名
        //private static final String USER="用户名";//用户名
        //private static final String PASSWORD="密码";//密码
        try {
            //1.加载驱动程序 此语句固定,使用MySQL数据库无需更改,在JSP中可不加异常处理
            //Class.forName("com.mysql.jdbc.Driver");

            //2.建立数据库的连接
            Connection con = DriverManager.getConnection(URL,USER,PASSWORD);

            //3.通过数据库的连接操作数据库
            Statement sql = con.createStatement();
           // String new_member = "delete from sqls where sql1 = 'sql2'";

            //String new_member = "delete from sqls where sql4='1'"; //删除某行
            String new_member = "ALTER TABLE sqls CHANGE 'sql3' 'sql22' VARCHAR(10)"; //修改某行字段

            sql.executeUpdate(new_member);

            //4.发送执行
            sql.executeUpdate(new_member);

            con.close();//断开数据库连接
        }
        catch(SQLException E) {
            System.out.println("SQL异常!!!!");
            System.out.println(E); //打印异常
        }
    }

注意事项 接口写法必须有 SQLException 方法,否则会报错。

 catch(SQLException E) {
            System.out.println("SQL异常!!!!");
            System.out.println(E); //打印异常
        }

实例:



@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})

public class DemoApplication {
    private static  String URL = "jdbc:mysql://101.43.123.237:3306/sql_liwnute_com";//jdbc:mysql//服务器地址/数据库名
    private static  String USER = "sql_liwnute_com";//用户名
    private static  String PASSWORD = "rootroot";//密码

    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);

        System.out.println("\n开始:\n"); //打印异常

        zengSQL();
        chaSQL();
        gaiSQL();
        shanSQL();
    }

    //SQL新增数据
    public static void zengSQL() {
        //private static final String URL="jdbc:mysql://localhost:3306/数据库名";//jdbc:mysql//服务器地址/数据库名
        //private static final String USER="用户名";//用户名
        //private static final String PASSWORD="密码";//密码
        try {
            //1.加载驱动程序 此语句固定,使用MySQL数据库无需更改,在JSP中可不加异常处理
            //Class.forName("com.mysql.jdbc.Driver");

            //2.建立数据库的连接
            Connection con = DriverManager.getConnection(URL,USER,PASSWORD);

            //3.通过数据库的连接操作数据库,实现新增数据
            Statement sql = con.createStatement();
            String new_member = "insert into sqls(sql1,sql2,sql3) values('表单值1','表单值2','表单值3')";

            //一次增加多条数据
            //String new_member="insert into 表名(表单名1,表单名2)"
            //new_menber += "values('表单值1','表单值2'),";
            //new_menber += "('表单值1','表单值2')";

            //4.执行发送
            sql.executeUpdate(new_member);
            con.close();//断开数据库连接
        }
        catch(SQLException E) {
            System.out.println("SQL异常!!!!");
            System.out.println(E); //打印异常
        }
    }

    //SQL查找数据
    public static void chaSQL() {
        //private static final String URL="jdbc:mysql://localhost:3306/数据库名";//jdbc:mysql//服务器地址/数据库名
        //private static final String USER="用户名";//用户名
        //private static final String PASSWORD="密码";//密码
        try {
            //1.加载驱动程序 此语句固定,使用MySQL数据库无需更改,在JSP中可不加异常处理
            //Class.forName("com.mysql.jdbc.Driver");

            //2.建立数据库的连接
            Connection con = DriverManager.getConnection(URL,USER,PASSWORD);

            //3.通过数据库的连接操作数据库,实现查找数据
            Statement sql = con.createStatement();

            //4.执行发送
            ResultSet rs = sql.executeQuery("select * from sqls");

            //5.打印数据表结果
            while (rs.next()) {
                System.out.println(rs.getString("sql1"));//表单名,即表头//数据库设计时,表头使用英文
            }

            con.close();//断开数据库连接
        }
        catch(SQLException E) {
            System.out.println("SQL异常!!!!");
            System.out.println(E); //打印异常
        }
    }

    //SQL修改数据
    public static void gaiSQL() {
        //private static final String URL="jdbc:mysql://localhost:3306/数据库名";//jdbc:mysql//服务器地址/数据库名
        //private static final String USER="用户名";//用户名
        //private static final String PASSWORD="密码";//密码
        try {
            //1.加载驱动程序 此语句固定,使用MySQL数据库无需更改,在JSP中可不加异常处理
            //Class.forName("com.mysql.jdbc.Driver");

            //2.建立数据库的连接
            Connection con = DriverManager.getConnection(URL,USER,PASSWORD);

            //3.通过数据库的连接操作数据库
            Statement sql = con.createStatement();
           // String new_member = "update sqls set sql1='表单值123',sql2='表单值2345' where sql2=10";
            String new_member = "update sqls set sql1='表单值123',sql2='表单值2345'";
            //name='qjh' where id=1;

            //4.发送执行
            sql.executeUpdate(new_member);

            con.close();//断开数据库连接
        }
        catch(SQLException E) {
            System.out.println("SQL异常!!!!");
            System.out.println(E); //打印异常
        }
    }

    //SQL删除数据
    public static void shanSQL() {
        //private static final String URL="jdbc:mysql://localhost:3306/数据库名";//jdbc:mysql//服务器地址/数据库名
        //private static final String USER="用户名";//用户名
        //private static final String PASSWORD="密码";//密码
        try {
            //1.加载驱动程序 此语句固定,使用MySQL数据库无需更改,在JSP中可不加异常处理
            //Class.forName("com.mysql.jdbc.Driver");

            //2.建立数据库的连接
            Connection con = DriverManager.getConnection(URL,USER,PASSWORD);

            //3.通过数据库的连接操作数据库
            Statement sql = con.createStatement();
           // String new_member = "delete from sqls where sql1 = 'sql2'";

            //String new_member = "delete from sqls where sql4='1'"; //删除某行
            String new_member = "ALTER TABLE sqls CHANGE 'sql3' 'sql22' VARCHAR(10)"; //修改某行字段

            sql.executeUpdate(new_member);

            //4.发送执行
            sql.executeUpdate(new_member);

            con.close();//断开数据库连接
        }
        catch(SQLException E) {
            System.out.println("SQL异常!!!!");
            System.out.println(E); //打印异常
        }
    }

}

684 Views
分享你的喜爱
linwute
linwute

我要像梦一样自由,像大地一样宽容;
在艰辛放逐的路上,点亮生命的光芒;
我要像梦一样自由,像天空一样坚强;
在曲折蜿蜒的路上,体验生命的意义;

留下评论

您的电子邮箱地址不会被公开。 必填项已用 * 标注