java连接Mysql数据库

首先安装好mysql数据库，然后建了个数据库以及相应的表。

创建数据库的sql语句如下：

create database mytest;
create table user_table(
 id varchar(20) primary key,
 password varchar(20),
 other varchar(20)
)
insert into user_table(id, password, other)values('001','123','');
insert into user_table(id, password, other)values('002','123','');
insert into user_table(id, password, other)values('003','123','');
insert into user_table(id, password, other)values('004','123','');
insert into user_table(id, password, other)values('005','123','');

创建好数据库后在eclipse中创建一个java项目，然后加载数据库驱动，我用的是：mysql-connector-java-5.0.4-bin.jar。

然后就开始编写连接数据库代码。具体如下：

package cn.server.database;

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

public class ConnectMysql {

	private String Dr = "com.mysql.jdbc.Driver";
	private String url = "jdbc:mysql://localhost:3306/mytest";
	private String userName = "root";
	private String password = "liuwu";
	private String sql = null;
	
	Connection conn = null;
	Statement sm = null;
	ResultSet rs = null;
	
	public ConnectMysql(String sql)
	{
		this.sql = sql;
		InitDb();
//		ExecuteSql();
	}
	public void InitDb()
	{
		try {
			Class.forName(Dr);
			
		} catch (ClassNotFoundException e) {
			System.out.println("无法加载驱动程序");
		}
		try {
			conn = DriverManager.getConnection(url, userName, password);
			sm = conn.createStatement();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
	}
	public void ExecuteSql()
	{
		String id = null;
		String pwd = null;
		try {
			rs = sm.executeQuery(sql);
			while(rs.next())
			{
				id = rs.getString("id");
				pwd = rs.getString("password");
				System.out.println("id="+id+"  pwd="+pwd);
				
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}

	}
	
	public static void main(String[] agrs)
	{
		String sql = "select id,password from user_table";
		ConnectMysql cm = new ConnectMysql(sql);
		cm.ExecuteSql();
	}
}

运行下连接成功~