标签：JDBC Java forName 改查 System jdbc println Class out

import java.sql.*;
import java.util.Scanner;

public class test00 {

    public static void main(String[] args) {
        int a;
        Scanner sc=new Scanner(System.in);
        while(true) {
            System.out.println("请输入操作:");
            System.out.println("1.增");
            System.out.println("2.删");
            System.out.println("3.改");
            System.out.println("4.查");
            System.out.println("5.查询所有");
            a=sc.nextInt();
            if(a>0&&a<6) {
                switch(a) {
                case 1:add();break;
                case 2:delete();break;
                case 3:update();break;
                case 4:dectet();break;
                case 5:all();break;
                }
            }
            else System.out.println("----输入错误---");
        }
        
    }
    
    
    
    private static void all() {
        PreparedStatement ps=null;
        ResultSet rs=null;
        String sql="select id,name,loc from test";
        ps=Util(sql);
        try {
            rs=ps.executeQuery(sql);
            while(rs.next()) {
                System.out.print(rs.getString("id")+"--");
                System.out.print(rs.getString("name")+"--");
                System.out.println(rs.getString("loc"));
            }
        } catch (SQLException e) {
            // TODO 自动生成的 catch 块
            e.printStackTrace();
        }
        try {
            rs.close();
        } catch (SQLException e) {
            // TODO 自动生成的 catch 块
            e.printStackTrace();
        }
        try {
            ps.close();
        } catch (SQLException e) {
            // TODO 自动生成的 catch 块
            e.printStackTrace();
        }
        
    }



    private static PreparedStatement Util(String sql) {
        Connection conn=null;
        PreparedStatement pt=null;
        ResultSet rs=null;
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/JDBCTest","root","zber1574");
            pt=conn.prepareStatement(sql);
        } catch (ClassNotFoundException | SQLException e) {
            e.printStackTrace();
        }
        return pt;
    }
    
    
    private static void dectet() {
        Scanner sc=new Scanner(System.in);
        PreparedStatement pr=null;
        Connection conn=null;
        ResultSet rs=null;
        String id,name,loc;
        System.out.println("请输入要c查询的id");
        id=sc.next();
        String sql="select id,name,loc from test";
        
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/JDBCTest","root","zber1574");
            pr=conn.prepareStatement(sql);
            rs=pr.executeQuery(sql);
            while(rs.next()){
                if(id.equals(rs.getString("id"))) {
                System.out.print(rs.getString("id")+"--");
                System.out.print(rs.getString("name")+"--");
                System.out.println(rs.getString("loc"));
            }
                }
        } catch (ClassNotFoundException | SQLException e) {
            e.printStackTrace();
        }
        
        

    }


    private static void update() {
        PreparedStatement pr=null;
        Scanner sc=new Scanner(System.in);
        String id,name,loc;
        System.out.println("请输入要更改的id");
        String U_id=sc.next();
        System.out.println("请输入要更改的name ,loc");
        name=sc.next();
        loc=sc.next();
        String sql="update test set id='"+U_id+"',name='"+name+"',loc='"+loc+"'where id='"+U_id+"'";
        System.out.println(sql);
        pr=Util(sql);
        try {
            int count=pr.executeUpdate();
            System.out.println(count==1?"更改成功":"更改失败");
        } catch (SQLException e) {
            
            e.printStackTrace();
        }
        
    }

    private static void delete() {
        PreparedStatement pr=null;
        Scanner sc=new Scanner(System.in);
        String id,name,loc;
        System.out.println("请输入要删除的id");
        id=sc.next();
        String sql="delete from test where id ="+id;
        pr=Util(sql);
        try {
            int count=pr.executeUpdate();
            System.out.println(count==1?"删除成功":"删除失败");
        } catch (SQLException e) {
            // TODO 自动生成的 catch 块
            e.printStackTrace();
        }
    }

    private static void add() {
        Scanner sc=new Scanner(System.in);
        String id,name,loc;
        System.out.println("输入id,name,loc");
        id=sc.next();
        name=sc.next();
        loc=sc.next();
        PreparedStatement pr=null;
        String sql= null;
        System.out.println();
        sql="insert into test (id,name,loc) values(?,?,?)";
        pr=Util(sql);
        try {
            pr.setString(1, id);
            pr.setString(2, name);
            pr.setString(3, loc);
            int count=pr.executeUpdate();
            System.out.println(count==1?"添加成功":"添加失败");
            
        } catch (SQLException e) {
            e.printStackTrace();
        }
        
    }

}

自己尝试做的Java程序连接数据库完成增删改查，

连接数据库步骤分别是加载驱动程序：

Class.forName(driverClass)
//加载MySql驱动
Class.forName("com.mysql.jdbc.Driver")
//加载Oracle驱动
Class.forName("oracle.jdbc.driver.OracleDriver")

获得数据库连接：

DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/imooc", "root", "root");

创建Statement\PreparedStatement对象：

conn.createStatement();
conn.prepareStatement(sql);

标签：JDBC,Java,forName,改查,System,jdbc,println,Class,out
来源： https://www.cnblogs.com/Rebz/p/15587235.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。