JDBC数据库操作

---

JDBC:

　　  创建SQL语句对象    Statement statement = (Statement) con.createStatement() ;

　　  调用执行　　　    　statement.executeUpdate(sqlString);

　　  释放资源           　　statement.close();

  一 :  创建表的操作代码:

package JDBC;

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

import com.mysql.jdbc.Statement;

public class Demo {
    // 数据库地址
    private static String dbUrl="jdbc:mysql://localhost:3306/JavaJDBC";
    // 用户名
    private static String dbUserName="root";
    // 密码
    private static String dbPassword="root";
    // 驱动名称
    private static String jdbcName="com.mysql.jdbc.Driver";
    
    public static void main(String[] args) {
        try {
            Class.forName(jdbcName);
            System.out.println("加载驱动成功！");
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            System.out.println("加载驱动失败！");
        }
        Connection con=null;
        try {
            // 获取数据库连接
            con=DriverManager.getConnection(dbUrl, dbUserName, dbPassword);
            System.out.println("获取数据库连接成功！");
            System.out.println("进行数据库操作！");
            // 创建sql语句
            String sqlString =  "CREATE TABLE t_student(id BIGINT PRIMARY KEY AUTO_INCREMENT,name VARCHAR(20),age INT)";
            // 创建语句对象
            Statement statement = (Statement) con.createStatement() ;
            // 执行sql语句
            statement.executeUpdate(sqlString);
            statement.close();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            try {
                con.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }
    
}

二 : 处理异常和关闭资源(对上部分代码优化)

package JDBC;

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

import com.mysql.jdbc.Statement;

public class Demo {
    // 数据库地址
    private static String dbUrl="jdbc:mysql://localhost:3306/JavaJDBC";
    // 用户名
    private static String dbUserName="root";
    // 密码
    private static String dbPassword="root";
    
    public static void main(String[] args) {
        Connection con=null;
        Statement statement = null ;
        try {
            // 获取数据库连接
            con=DriverManager.getConnection(dbUrl, dbUserName, dbPassword);
            System.out.println("获取数据库连接成功！");
            System.out.println("进行数据库操作！");
            // 创建sql语句
            String sqlString =  "CREATE TABLE t_student(id BIGINT PRIMARY KEY AUTO_INCREMENT,name VARCHAR(20),age INT)";
            // 创建语句对象
            statement = (Statement) con.createStatement() ;
            // 执行sql语句
            statement.executeUpdate(sqlString);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            try {
                con.close();
                statement.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }
    
}

三 : DML操作

　　操作与上述常见表相同,只需修改SQL语句

四 : 查询操作

　　

package JDBC;

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

import com.mysql.jdbc.ResultSet;
import com.mysql.jdbc.Statement;

public class Demo {
    // 数据库地址
    private static String dbUrl="jdbc:mysql://localhost:3306/JavaJDBC";
    // 用户名
    private static String dbUserName="root";
    // 密码
    private static String dbPassword="root";
    
    public static void main(String[] args) throws ClassNotFoundException {
        Class.forName("com.mysql.jdbc.Driver") ;
        Connection con=null;
        Statement statement = null ;
        try {
            // 获取数据库连接
            con=DriverManager.getConnection(dbUrl, dbUserName, dbPassword);
            System.out.println("获取数据库连接成功！");
            System.out.println("进行数据库操作！");
            // 创建sql语句
            String sqlString =  "select * from t_student";
            // 创建语句对象
            statement = (Statement) con.createStatement() ;
            // 执行sql语句
            ResultSet resultSet = (ResultSet) statement.executeQuery(sqlString);
            // 取出查询结果
            while(resultSet.next()){
                long id = resultSet.getLong("id") ;
                String nameString = resultSet.getString("name") ;
                long age = resultSet.getLong("age") ;
                System.out.println(id + " " + nameString + " " + age);
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            try {
                con.close();
                statement.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }
    
}

核心代码:

            // 执行sql语句
            ResultSet resultSet = (ResultSet) statement.executeQuery(sqlString);
            // 取出查询结果
            while(resultSet.next()){
                long id = resultSet.getLong("id") ;
                String nameString = resultSet.getString("name") ;
                long age = resultSet.getLong("age") ;
                System.out.println(id + " " + nameString + " " + age);
            }

　　解释:   executeQuery返回一个ResultSet,是对应的表,开始指向第一行,也就是每一列的名称,此处为id,name,age,然后通过next()将光标下移,通过getLong(String 列名称)取出 或 getLong(Long 列号)取出(从1开始).