java访问mysql数据库

package com.mysql.test;

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

public class JDBC_Test1 {
    // 创建静态全局变量
    static Connection conn;

    static Statement st;

    public static void main(String[] args) {
        //insert();    //插入添加记录
        //update();    //更新记录数据
        //delete();    //删除记录
        query();    //查询记录并显示
    }
    
    /* 插入数据记录，并输出插入的数据记录数*/
    public static void insert() {
        
        conn = getConnection();    // 首先要获取连接，即连接到数据库

        try {
            st = (Statement) conn.createStatement();    // 创建用于执行静态sql语句的Statement对象
            
            String sql = "INSERT INTO employee(num, d_id, name,age, sex, homeaddr)"
                    + " VALUES (8, 1007, '***', 66,'男','北京朝阳区')";    // 插入数据的sql语句
            
            int count = st.executeUpdate(sql);    // 执行插入操作的sql语句，并返回插入数据的个数
            
            System.out.println("向employee表中插入 " + count + " 条数据");    //输出插入操作的处理结果
            
            conn.close();    //关闭数据库连接
            
        } catch (SQLException e) {
            System.out.println("插入数据失败" + e.getMessage());
        }
    }
    
    /* 更新符合要求的记录，并返回更新的记录数目*/
    public static void update() {
        conn = getConnection();    //同样先要获取连接，即连接到数据库
        try {
            st = (Statement) conn.createStatement();    //创建用于执行静态sql语句的Statement对象，st属局部变量
            
            String sql = "update employee set name='奥巴马' where d_id = 1006";// 更新数据的sql语句
            
            int count = st.executeUpdate(sql);// 执行更新操作的sql语句，返回更新数据的个数
            
            System.out.println("employee表中更新 " + count + " 条数据");        //输出更新操作的处理结果
            
            conn.close();    //关闭数据库连接
            
        } catch (SQLException e) {
            System.out.println("更新数据失败");
        }
    }

    /* 查询数据库，输出符合要求的记录的情况*/
    public static void query() {
        
        conn = getConnection();    //同样先要获取连接，即连接到数据库
        try {
            st = (Statement) conn.createStatement();    //创建用于执行静态sql语句的Statement对象，st属局部变量
            String sql = "select * from employee";        // 查询数据的sql语句
            
            ResultSet rs = st.executeQuery(sql);    //执行sql查询语句，返回查询数据的结果集
            System.out.println("最后的查询结果为：");
            while (rs.next()) {    // 判断是否还有下一个数据
                
                // 根据字段名获取相应的值
                int num = rs.getInt("num");
                int d_id = rs.getInt("d_id");
                String name = rs.getString("name");
                int age = rs.getInt("age");
                String sex = rs.getString("sex");
                String homeaddr = rs.getString("homeaddr");
                
                //输出查到的记录的各个字段的值
                System.out.println(num + " " + d_id + " " + name + " " + age
                        + " " + sex + " " + homeaddr);
            
            }
            conn.close();    //关闭数据库连接
            
        } catch (SQLException e) {
            System.out.println("查询数据失败");
        }
    }

    /* 删除符合要求的记录，输出情况*/
    public static void delete() {

        conn = getConnection();    //同样先要获取连接，即连接到数据库
        try {
            st = (Statement) conn.createStatement();    //创建用于执行静态sql语句的Statement对象，st属局部变量
            
            String sql = "delete from employee  where d_id = 1005";// 删除数据的sql语句
            
            int count = st.executeUpdate(sql);// 执行sql删除语句，返回删除数据的数量
            
            System.out.println("employee表中删除 " + count + " 条数据
");    //输出删除操作的处理结果
            
            conn.close();    //关闭数据库连接
            
        } catch (SQLException e) {
            System.out.println("删除数据失败");
        }
        
    }
    
    /* 获取数据库连接的函数*/
    public static Connection getConnection() {
        Connection con = null;    //创建用于连接数据库的Connection对象
        try {
            Class.forName("com.mysql.jdbc.Driver");// 加载Mysql数据驱动
            
            con = DriverManager.getConnection(
                    "jdbc:mysql://localhost:3306/company", "root", "hjf19920121");// 创建数据连接
            
        } catch (Exception e) {
            System.out.println("数据库连接失败" + e.getMessage());
        }
        return con;    //返回所建立的数据库连接
    }
}

package com.mysql.test;

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

public class JDBC_test {
    static Connection connection = null;
    public static void main(String[] args) {
        executeTest();
        
    }
    /* 获取数据库连接的函数*/
    public static Connection getConnection() {
        String url = "jdbc:mysql://localhost:3306/company";//获取协议,IP和端口等信息
        String user = "root";//获取数据库用户名
        String password = "hjf19920121";//获取数据库用户密码
        
        try {
            Class.forName("com.mysql.jdbc.Driver");//指定JDBC驱动的类型
            connection = DriverManager.getConnection(url, user, password);
        } catch (Exception e) {
                e.printStackTrace();System.out.println("数据库连接失败" + e.getMessage());
        }
        
        return connection;
    }
    
    public static void executeTest() {
        connection = getConnection();//同样先要获取连接，即连接到数据库
        try {
            Statement statement = connection.createStatement();//创建Statement对象
            
            String sql = "delete from employee  where d_id = 1005";
            
            boolean st = statement.execute(sql);//如果sql语句是select语句，该方法返回true，如果是update，insert，delete语句该方法返回false
            if(st==true){
                ResultSet result = statement.executeQuery(sql);
                
                System.out.println("最后的查询结果为：");
                
                while(result.next()){
                    // 根据字段名获取相应的值
                    int num = result.getInt("num");
                    int d_id = result.getInt("d_id");
                    String name = result.getString("name");
                    int age = result.getInt("age");
                    String sex = result.getString("sex");
                    String homeaddr = result.getString("homeaddr");
                    
                    //输出查到的记录的各个字段的值
                    System.out.println(num + " " + d_id + " " + name + " " + age
                            + " " + sex + " " + homeaddr);
                }
            }
            else{
                int i = statement.getUpdateCount();//获取发生变化的记录数
                System.out.println(i);
            }
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}