JDBC编程的步骤

版权所有,禁止匿名转载;禁止商业使用。

一、进行JDBC编程的步骤大致如下:


1.      加载数据库驱动,通常使用Class类的forName()静态方法来加载驱动。如下代码:


Class.forName(dirvirClass)


上面代码中的driverClass就是数据库驱动类所对应的字符串


加载MySQL数据库时采用的代码为:


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


2.      通过DriverManager获取数据库连接。


DriverManager.getConnection(String url,String user,Stringpass)


使用DriverManager获取数据库连接时,需要传入3个参数:数据库URL、登陆数据库的用户名和密码。


数据库URL通常遵循如下写法:


jdbc:subprotocol:other stuff.


连接MySQL数据库时的URL写法为:


jdbc:mysql://localhost/BDYun


3.      通过Connection对象创建Statement对象。Connection创建Statement的方法有如下3个:


(1)      createStatement():创建基本的Statement对象


(2)      prepareStatement(String sql):根据传入的SQL语句创建预编译的Statement对象


(3)      prepareCall(String sql):根据传入的SQL语句创建CallableStatement对象


4.      使用Statement执行SQL语句。所有的Statement都有如下3个方法来执行SQL语句:


(1)      execute():可以执行任何SQLyu7ju,但比较麻烦


(2)      executeUpdate():主要用于执行DML和DDL语句。执行DML语句返回受SQL语句影响的行数,执行DDL语句返回0.


(3)      executeQuery():只能执行查询语句,执行后返回代表查询结果的ResultSet对象


5.      操作结果集。如果执行的SQL语句是查询语句,则执行结果将返回一个ResultSet对象,该对象里保存了SQL语句查询的结果。程序可以通过操作该ResultSet对象来取出查询结果。ResultSet对象主要提供了如下两类方法。


(1)next()、previous()、first()、last()、beforeFirst()、afterLast()、absolute()等移动记录指针的方法。


(2)getXxx()方法获取记录指针指向行、特定列的值。该方法既可以使用列索引作为参数,也可以使用列名称作为参数。使用列索引作为参数性能更好,使用列名称作为参数可读性更好。


6.      回收数据库资源,包括关闭ResultSet、Statement和Connection等资源。


二、代码演示


利用MySQL创建一个数据库BDYun,并在数据库中新建一个表POI,往表中插入两条数据

create database BDYun;

use database BDYun;

create table POI(id int(11) auto_incrementprimary key,latitude varchar(255),longitude varchar(255),picurlvarchar(255),serviceurl varchar(255) );

insert into poi values(null,36.0333,118.7833,null,null);

insert into poivalues(null,37.3333,116.3333,null,null);


在eclipse中创建一个新项目,并导入jar包:mysql-connector-java-5.1.30.bin.jar


(1)创建查询类,代码如下:

package com.jdbc;

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

public class ConnMySQLTest
{

  public static void main(String[] args) throws Exception 
  {
    // TODO Auto-generated method stub
    try
    {
      Class.forName("com.mysql.jdbc.Driver");
    
    
    Connection conn = DriverManager.getConnection("jdbc:mysql://localhost/BDYun","root","340621");
    Statement stmt = conn.createStatement();
    
    String sql = "select * from poi";
    ResultSet rs = stmt.executeQuery(sql);
    
    while(rs.next())
    {
      System.out.println("id:"+rs.getInt(1)+"纬度:"+rs.getString(2)+"经度:"+rs.getString(3));
    }
    } catch (ClassNotFoundException e)
    {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }
  }

}

程序运行结果如下:

20141114222015729.png


(2)利用executeUpdate方法执行DDL和DML语句


代码如下:

package com.jdbc;

import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
import java.util.Properties;



public class ExecuteUpdateTest
{		
  public void createTable(String sql) throws Exception
  {		
    Class.forName("com.mysql.jdbc.Driver");
    Connection conn = DriverManager.getConnection("jdbc:mysql://localhost/BDYun","root","340621");
    Statement stmt = conn.createStatement();
        {
      stmt.executeUpdate(sql);
        }
        
  }
  public static void main(String[] args) throws Exception
  {
    // TODO Auto-generated method stub		
    ExecuteUpdateTest eut = new ExecuteUpdateTest();		
    String sql = "create table camera (id int auto_increment primary key,latitude varchar(20),longitude varchar(20),picurl varchar(20),serviceurl varchar(20))";
    eut.createTable(sql);
    
    System.out.println("建表成功");
  }

}

程序执行成功后,登陆mysql数据库,可以看到数据库中出现了刚才创建的表格


  20141114222330859.png

(3)利用executeUpdate方法执行插入语句

package com.jdbc;

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

public class ExecuteUpdateInsertTest
{
  public int insertData(String sql) throws Exception
  {
    Class.forName("com.mysql.jdbc.Driver");
    Connection conn = DriverManager.getConnection(
        "jdbc:mysql://localhost/BDYun", "root", "340621");
    Statement stmt = conn.createStatement();
    {
      return stmt.executeUpdate(sql);
    }

  }

  public static void main(String[] args) throws Exception
  {
    
    ExecuteUpdateInsertTest ed = new ExecuteUpdateInsertTest();
    String sql = "insert into poi values(null,120.5333,34.6555,null,null)";
    int result = ed.insertData(sql);
    System.out.println("数据库表中共有"+result+"条记录受影响");

  }

}


0 0