java（jdbc）

     b.使用jdbc发送sql条件

           连接mysql数据库数据库主机端口、数据库、用户名、数据库密码、连接的数据库。

     c.核心api

         Driver接口： 数据库驱动程序的接口，所有具体数据库厂商需要的驱动程序需要实现此接口。

                           Connectionconnect(String url, Properties info)  用于获取数据库连接

         Connection接口：与具体的数据库的连接对象。

                   StatementcreateStatement()    创建一个静态sql语句对象

                   PreparedStatementprepareStatement(String sql)  创建预编译的sql语句对象

                  CallableStatementprepareCall(String sql)   创建存储过程的sql语句对象

        Statement接口：用于执行静态 SQL 语句

                  intexecuteUpdate(String sql)  执行更新操作的sql语句                                                                     （create/alter/drop) DDL语句

                  (insert/update/delete）DML语句

                  ResultSetexecuteQuery(String sql)  执行查询操作的sql语句

                  (select)（DQL查询语句）

         PreparedStatement接口：用于执行预编译的SQL语句（是Statement的子接口）

                   intexecuteUpdate()  执行更新操作的sql语句

                   ResultSetexecuteQuery()  执行查询操作的sql语句

         CallableStatement接口：用于执行 SQL 存储过程的接口（是PreparedStatement子接口）

                    ResultSetexecuteQuery()  执行存储过程的sql语句

         ResultSet接口：结果集对象。 存储所有数据库查询的结果，用该对象进行数据遍历。

                      booleannext():把光标移动到下一行。如果下一行有数据，返回true，如果没有下一行数                      据，返回false。

                     getXXX（列索引|列字段名称）： 获取字段的数据

        public class DriverDemo {

private static String url = "jdbc:mysql://localhost:3306/day20";

    //jdbc协议:mysql协议://主机地址:端口号/需要连接的数据库名称

private static String user = "root";

private static String password="root";

public static void main(String[] args) throws Exception {

/**

* java程序连接mysql数据库

* 1.mysql数据库的主机地址

* 2.端口号

* 3.用户名

* 5.密码

* 6.需要连接的数据库

* 

* 先使用java程序连接我们的数据库，需要一个连接对象Connection

*/

//conn1();

//conn2();

conn3();

}

private static void conn3() throws Exception {

//注册驱动，mysql驱动程序的Driver实现类已经在静态代码块中注册好了驱动，只需要将              Driver实现类加载到我们的内存中，static代码块就会自动执行

//注册驱动

Class.forName("com.mysql.jdbc.Driver");

//获取java连接数据库的对象

Connection conn = DriverManager.getConnection(url, user, password);

//打印这个连接对象

System.out.println(conn);

}

private static void conn2() throws Exception {

//使用驱动管理类，连管理我们的驱动程序，并获取连接

//1.注册驱动

//public static void registerDriver(Driver driver)throws SQLException

Driver driver = new com.mysql.jdbc.Driver();

DriverManager.registerDriver(driver);

//获取连接

//public static Connection getConnection(String url,String user,String password)throws SQLException

Connection conn = DriverManager.getConnection(url, user, password);

//打印这里数据库连接

System.out.println(conn);

}

//直连

private static void conn1() throws SQLException {

//创建一个驱动类对象Driver

Driver driver = new com.mysql.jdbc.Driver();

//获取java连接数据库的连接

//Connection connect(String url, Properties info)throws SQLException

//创建一个properties集合

Properties prop = new Properties();

prop.setProperty("user", user);

prop.setProperty("password", password);

Connection conn = driver.connect(url, prop);

//打印这个连接对象，如果连接对象不为空，就说明我们已经成功获取到了连接对象

System.out.println(conn);

}

     }

2.Statement对象执行SQL操作

        public class Demo {

private static String url = "jdbc:mysql://localhost:3306/day20";

private static String user = "root";

private static String password = "root";

public static void main(String[] args){

Connection conn = null;

Statement stmt = null;

try {

//注册驱动

Class.forName("com.mysql.jdbc.Driver");

//通过驱动管理类获取数据库连接

conn = DriverManager.getConnection(url, user, password);

//创建语句执行者

stmt = conn.createStatement();

//int executeUpdate(String sql)

//throws SQLException执行给定 SQL 语句，

//该语句可能为 INSERT、UPDATE 或 DELETE 语句，或者不返回任何内容的 SQL 语句       （如 SQL DDL 语句）。

String sql = "CREATE TABLE student("+

"id INT,"+

"NAME VARCHAR(20),"+

"age INT"+

");";

//使用语句执行者执行创建的sql语句

int count = stmt.executeUpdate(sql);

//打印一下影响的结果

System.out.println(count);

} catch (Exception e) {

e.printStackTrace();

throw new RuntimeException();

}finally{

//释放资源

if (conn!=null) {

try {

conn.close();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

if (stmt!=null) {

try {

stmt.close();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

}

   }

3.执行DML操作

        public class Demo2 {

private static String url = "jdbc:mysql://localhost:3306/day20";

private static String user = "root";

private static String password = "root";

public static void main(String[] args) {

//testInsert();//给数据库添加一条记录

//testUpdate();//修改数据库中的一条数据

testDelete();

}

private static void testDelete() {

//需求：将刘德华改为岳云鹏

Connection conn = null;

Statement stmt = null;

try{

//2.获取连接对象

conn  =JDBCUtil.getConn();

//3.准备sql

String sql = "DELETE FROM student WHERE id=1;";

//4.获取语句执行者

stmt = conn.createStatement();

//5.发送兵长执行sql

int count = stmt.executeUpdate(sql);

//打印影响的行数

System.out.println(count);

}catch(Exception e){

e.printStackTrace();

throw new RuntimeException();

}finally{

JDBCUtil.close(conn, stmt, null);

}

}

private static void testUpdate() {

//将刘德华改为岳云鹏

Connection conn = null;

Statement stmt = null;

try{

//1.注册驱动

Class.forName("com.mysql.jdbc.Driver");

//2.获取连接对象

conn  =DriverManager.getConnection(url, user, password);

//3.准备sql

String sql = "UPDATE student SET NAME=‘岳云鹏‘ WHERE id=1;";

//4.获取语句执行者

stmt = conn.createStatement();

//5.发送兵长执行sql

int count = stmt.executeUpdate(sql);

//打印影响的行数

System.out.println(count);

}catch(Exception e){

e.printStackTrace();

throw new RuntimeException();

}finally{

if (conn!=null) {

try {

conn.close();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

if (stmt!=null) {

try {

stmt.close();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

}

private static void testInsert() {

//专门测试添加功能

Connection conn = null;

Statement stmt = null;

try{

//注册驱动

Class.forName("com.mysql.jdbc.Driver");

//获取连接

conn = DriverManager.getConnection(url, user, password);

//定义sql

String sql = "INSERT INTO student VALUES(1,‘刘德华‘,50);";

//获取语句执行者

stmt = conn.createStatement();

//使用语句执行者发送并执行sql语句,并返回影响的行数

int count = stmt.executeUpdate(sql);

System.out.println(count);

}catch(Exception e){

e.printStackTrace();

throw new RuntimeException();

}finally{

//释放资源

if (conn!=null) {

try {

conn.close();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

if (stmt!=null) {

try {

stmt.close();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

}

    }

4.执行DQL查询操作

        public class Demo3 {

public static void main(String[] args) {

//定义一个连接对象和一个语句执行者

Connection conn  =null;

Statement stmt = null;

ResultSet rs = null;

try{

conn = JDBCUtil.getConn();

//定义sql

String sql = "SELECT * FROM student;";

//获取语句执行者对象

stmt = conn.createStatement();

//执行DQL查询语句

//ResultSet executeQuery(String sql)

            //throws SQLException执行给定的 SQL 语句，该语句返回单个 ResultSet 对象。

rs = stmt.executeQuery(sql);

//ResultSet是一个结果集

/*//判断有没有下一行数据

if (rs.next()) {

//说明有下一行数数据

System.out.println(rs.getInt(1)+"--"+rs.getString(2)+"--"+rs.getInt(3));

}

if (rs.next()) {

//说明有下一行数数据

System.out.println(rs.getInt(1)+"--"+rs.getString(2)+"--"+rs.getInt(3));

}

if (rs.next()) {

//说明有下一行数数据

System.out.println(rs.getInt(1)+"--"+rs.getString(2)+"--"+rs.getInt(3));

}

if (rs.next()) {

//说明有下一行数数据

System.out.println(rs.getInt(1)+"--"+rs.getString(2)+"--"+rs.getInt(3));

}

if (rs.next()) {

//说明有下一行数数据

//使用字段名称获取字段的每一个数据

while (rs.next()) {

//当我们使用字段名称去获取字段数据的时候，字段名称是不区分大小写

System.out.println(rs.getInt("ID")+"--"+rs.getString("NAME")+"--                              "+rs.getInt("AGE"));

}

}catch(Exception e){

e.printStackTrace();

}finally{

JDBCUtil.close(conn, stmt, rs);

}

}

    }

5.JDBC工具类的抽取

        public class JDBCUtil {

private static String url = "jdbc:mysql://localhost:3306/day20";

private static String user = "root";

private static String password = "root";

static{

//随着类的加载而夹在

try {

Class.forName("com.mysql.jdbc.Driver");

} catch (ClassNotFoundException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

//获取连接

public static Connection getConn(){

//注册驱动

try {

Connection conn = DriverManager.getConnection(url, user, password);

return conn;

} catch (Exception e) {

// TODO Auto-generated catch block

e.printStackTrace();

throw new RuntimeException();

}

}

//释放资源

public static void close(Connection conn,Statement stmt,ResultSet rs){

if (conn!=null) {

try {

conn.close();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

if (stmt!=null) {

try {

stmt.close();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

if (rs!=null) {

try {

rs.close();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

    }

java（jdbc）

标签：数据库连接   sql语句   java程序