java对mysql数据库的操作分为以下几个步骤：

1.获取连接：

获取连接需要两步，一是使用DriverManager来注册驱动，二是使用DriverManager来获取Connection对象。

Connection con = DriverManager.getConnection(“jdbc:mysql://localhost:3306/mydb1”,”root”,”123”);

JDBC规定url的格式由三部分组成，每个部分中间使用逗号分隔。

l第一部分是jdbc，这是固定的；

l第二部分是数据库名称，那么连接mysql数据库，第二部分当然是mysql了；

l第三部分是由数据库厂商规定的，我们需要了解每个数据库厂商的要求，mysql的第三部分分别由数据库服务器的IP地址(localhost)、端口号(3306)，以及DATABASE名称(mydb1)组成。

还可以在url中提供参数：

jdbc:mysql://localhost:3306/mydb1?useUnicode=true&characterEncoding=UTF8

useUnicode参数指定这个连接数据库的过程中，使用的字节集是Unicode字节集；

characherEncoding参数指定穿上连接数据库的过程中，使用的字节集编码为UTF-8编码。请注意，mysql中指定UTF-8编码是给出的是UTF8，而不是UTF-8。要小心了！

2.获取Statement

在得到Connectoin之后，说明已经与数据库连接上了，下面是通过Connection获取Statement对象的代码：

Statement stmt = con.createStatement();

Statement是用来向数据库发送要执行的SQL语句的！

3.发送sql语句

//增加，删除，修改,返回的i为影响的行数

String sql ="xxxx";

int i = stmt.excuteUpdate(sql);           //查询 返回为结果集，可以同过rs.next()进行遍历

//rs.next();//光标移动到第一行

//rs.getInt(1);//获取第一行第一列的数据

String sql = “select * from user”;

ResultSet rs = stmt.executeQuery(sql);

4.关闭资源

与IO流一样，使用后的东西都需要关闭！关闭的顺序是先得到的后关闭，后得到的先关闭。

rs.close();

stmt.close();

con.close();

自己简单的封装了一下，让访问的移植性变得较好一些，还未用到连接池：

package com.db;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

/**

* 连接池，访问量大时，多开几条访问通道，少了，就减少访问通道

* */

public class DbUtile {

//定义几个变量分别用于存放数据库信息,便于数据库的移植

private String getDriver="com.mysql.jdbc.Driver";

private String getUrl="jdbc:mysql://localhost:3306/db1";

private String getUser="root";

private String getPwd="root";

Connection conn = null;

Statement state = null;

ResultSet rs = null;

public Connection getConn()

{

try {

Class.forName(getDriver);

try {

conn = DriverManager.getConnection(getUrl, getUser, getPwd);

} catch (SQLException e) {

e.printStackTrace();

}

} catch (ClassNotFoundException e) {

System.out.println("无法找到驱动类！");

}

return conn;

}

public Statement getState()

{

try {

state = getConn().createStatement();

} catch (SQLException e) {

e.printStackTrace();

}

return state;

}

//用于修改，更新，增加

public int getModify(String sql)

{

int i=0;

try {

getState().executeUpdate(sql);

} catch (SQLException e) {

e.printStackTrace();

}finally{

closeRs();

closeState();

closeConn();

}

return i;

}

//用于查询

public ResultSet getSelect(String sql)

{

try {

rs = getState().executeQuery(sql);

} catch (SQLException e) {

e.printStackTrace();

}//这里不能关闭资源，，否则rs是空的

return rs;

}

//用于关闭资源

public void closeConn()

{

try {

if(conn!=null&&!conn.isClosed())

{

conn.close();

}

} catch (SQLException e) {

e.printStackTrace();

}

}

public void closeState()

{

try {

if(state!=null&&!state.isClosed())

{

state.close();

}

} catch (SQLException e) {

e.printStackTrace();

}

}

public void closeRs()

{

try {

if(rs!=null&&!rs.isClosed())

{

rs.close();

}

} catch (SQLException e) {

e.printStackTrace();

}

}

}

这是测试的类，查询时，不要在查询函数离关闭资源，否则拿到的是空的集合：

package com.db;

import java.sql.ResultSet;

import java.sql.SQLException;

public class TestDbUtile {

public static void main(String[] args)

{

DbUtile dbu = new DbUtile();

String sql = "insert into duser (name,pwd,email,ddate) values ('laowang','123','abc@163.com',now())";

dbu.getModify(sql);

String sql2="select * from duser";

ResultSet rs = dbu.getSelect(sql2);

try {

while(rs.next())

{

System.out.print(rs.getInt("id")+"\t");

System.out.print(rs.getString("name")+"\t");

System.out.print(rs.getString("pwd")+"\t");

System.out.print(rs.getString("email")+"\t");

System.out.println(rs.getDate("ddate")+"\t");

}

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}finally{

dbu.closeRs();

dbu.closeState();

dbu.closeConn();

}

}

}

有不当之处还请指教~~~