Java与MySQL数据库连接的实例 (java连接mysql数据库实例)

Java和MySQL分别是目前更流行的编程语言和关系型数据库之一。一个好的Web应用程序，需要Java和MySQL数据库之间的连接操作。在这篇文章中，我们将介绍如何使用Java连接MySQL数据库的实例。

我们需要安装MySQL数据库。可以通过去官网下载MySQL Community Edition来获取下载链接。在下载并安装完后，我们需要打开MySQL的命令行终端或MySQLworkbench，然后通过以下命令来创建一个数据库：

CREATE DATABASE test_database;

接着，我们需要创建一个数据表。以下是一个简单的创建表的实例：

CREATE TABLE test_table (

id INT NOT NULL AUTO_INCREMENT,

name VARCHAR(20) NOT NULL,

age INT NOT NULL,

PRIMARY KEY (id)

);

在以上代码中，我们创建了一个简单的表test_table，其中包含三个字段id、name和age。字段id为自动增长的整数，作为每行数据的唯一标识符；字段name为不超过20个字符的字符串；字段age为整数值。

接下来，我们需要创建一个Java的类，用于连接到MySQL数据库并执行相关的操作。以下是一个Java类的示例：

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

public class MySQLConnector {

private static final String JDBC_DRIVER = “com.mysql.jdbc.Driver”;

private static final String DB_URL = “jdbc:mysql://localhost:3306/test_database”;

// 数据库的用户名与密码，需要根据自己的设置进行修改

private static final String USER = “root”;

private static final String PASS = “123456”;

private Connection conn;

private Statement stmt;

public void connect() throws ClassNotFoundException {

try {

// 注册JDBC驱动

Class.forName(JDBC_DRIVER);

// 打开链接

conn = DriverManager.getConnection(DB_URL, USER, PASS);

// 执行查询

stmt = conn.createStatement();

String sql = “SELECT * FROM test_table”;

ResultSet rs = stmt.executeQuery(sql);

// 处理结果集

while(rs.next()){

int id = rs.getInt(“id”);

String name = rs.getString(“name”);

int age = rs.getInt(“age”);

System.out.print(“ID: ” + id);

System.out.print(“, Name: ” + name);

System.out.println(“, Age: ” + age);

}

// 关闭查询

rs.close();

stmt.close();

conn.close();

} catch (SQLException e) {

e.printStackTrace();

}

public static void mn(String[] args) throws ClassNotFoundException {

MySQLConnector mySQLConnector = new MySQLConnector();

mySQLConnector.connect();

System.out.println(“连接数据库成功”);

}

在以上代码中，我们创建了一个名为MySQLConnector的类，用来连接MySQL数据库。我们需要定义JDBC驱动的类路径 com.mysql.jdbc.Driver 和数据库的URL地址 jdbc:mysql://localhost:3306/test_database。然后，我们需要指定数据库的用户名和密码，以便程序可以连接到MySQL数据库。

该类中的connect()方法连接到数据库，并从test_table表中选择所有的行，然后将它们打印到控制台上。connect()方法关闭了ResultSet、Statement和Connection。

运行程序之后，我们可以看到在控制台输出了一些MySQL数据库的数据。这就证明了程序已经成功地连接到了MySQL数据库。

以上介绍了如何使用Java连接MySQL数据库的实例，包括如何创建MySQL数据库和数据表，以及如何创建一个Java类来连接MySQL数据库，并从其中查询数据。这些步骤将帮助我们更好地了解如何使用Java适当地连接到MySQL数据库。

相关问题拓展阅读：

如何在Java程序中访问mysql数据库中的数据并进行简单的操作

/**

*获取数据库的连接

*@returnconn

publicstaticConnectiongetConnection()throwsException{

Stringurl=“jdbc:

Stringuser=“opermain”;

Stringpsw=“opermain”;

Connectionconn=null;

PreparedStatementpstm=null;

ResultSetrs=null;

Class.forName(“com.mysql.jdbc.Driver”);

if(null==conn){

try{

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

}catch(SQLExceptione){

System.out.println(“获取失败”);

thrownewRuntimeException(e);

}finally{

closeResources(conn,pstm,rs);

}

returnconn;

}

/**

*释放资源

*@paramconn

*@parampstmt

*@paramrs

publicstaticvoidcloseResources(Connectionconn,PreparedStatementpstmt,ResultSetrs){

if(null!=rs){

try{

rs.close();

}catch(SQLExceptione){

e.printStackTrace();

thrownewRuntimeException(e);

}finally{

if(null!=pstmt){

try{

pstmt.close();

}catch(SQLExceptione){

e.printStackTrace();

thrownewRuntimeException(e);

}finally{

if(null!=conn){

try{

conn.close();

}catch(SQLExceptione){

e.printStackTrace();

thrownewRuntimeException(e);

}

////tuserrole执行插入

//try{

//Stringsql=“insertintosys_userrole(roleid,userid)values(?,?)”;

//conn=getConnection();

//conn.setAutoCommit(false);

//PreparedStatementpstmt=(PreparedStatement)conn.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);//传入参数：Statement.RETURN_GENERATED_KEYS

//pstmt.setInt(1,5);

//pstmt.setInt(2,sid);

//pstmt.executeUpdate();

//ResultSetrs=pstmt.getGeneratedKeys();//获取结果

//inta=-1;

//if(rs.next()){

//a=rs.getInt(1);//取得ID

//}

//System.out.println(a);

//System.out.println(“t_userrole执行成功”);

//conn.commit();

//}catch(Exceptione){

//e.printStackTrace();

//System.out.println(“执行失败”);

//}

创建一个javaProject，并输入如下java代码：

package link;

import java.sql.*;

/**

* 使用JDBC连接数据库MySQL的过程

* DataBase：， table：person；

* 使用myeclipse对mysql数据库进行增删改查的基本操作。

public class JDBCTest {

public static Connection getConnection() throws SQLException,

java.lang.ClassNotFoundException

{

//之一步：加载MySQL的JDBC的驱动

Class.forName(“com.mysql.jdbc.Driver”);

//取得连接的url,能访问MySQL数据库的用户名,密码；jsj：数据库名

String url = “jdbc:

String username = “root”;

String password = “”;

//第二步：创建与MySQL数据库的连接类的实例

Connection con = DriverManager.getConnection(url, username, password);

return con;

}

public static void main(String args) {

try

{

//第三步：获取连接类实例con，用con创建Statement对象类实例 sql_statement

Connection con = getConnection();

Statement sql_statement = con.createStatement();

//如果同名数据库存在，删除

//sql_statement.executeUpdate(“drop table if exists student”);

//执行了一个sql语句生成了一个名为student的表

//sql_statement.executeUpdate(“create table student (id int not null auto_increment, name varchar() not null default ‘name’, math int not null default , primary key (id) ); “);

//向person表中插入数据

sql_statement.executeUpdate(“insert person values(, ‘liying’, )”);

sql_statement.executeUpdate(“insert person values(, ‘jiangshan’, )”);

sql_statement.executeUpdate(“insert person values(, ‘wangjiawu’, )”);

sql_statement.executeUpdate(“insert person values(, ‘duchangfeng’, )”);

//第四步：执行查询，用ResultSet类的对象，返回查询的结果

String query = “select * from person”;

ResultSet result = sql_statement.executeQuery(query);

//显示数据中person表中的内容：

System.out.println(“person表中的数据如下:”);

System.out.println(“”);

System.out.println(“序号” + ” ” + “姓名” + ” ” + “分数”);

System.out.println(“”);

//对获得的查询结果进行处理，对Result类的对象进行操作

while (result.next())

{

int number = result.getInt(“number”);

String name = result.getString(“name”);

String mathsorce = result.getString(“mathsorce”);

//取得数据库中的数据

System.out.println(” ” + number + ” ” + name + ” ” + mathsorce);

}

//关闭连接和声明

sql_statement.close();

con.close();

} catch(java.lang.ClassNotFoundException e) {

System.err.print(“ClassNotFoundException”);

System.err.println(e.getMessage());

} catch (SQLException ex) {

System.err.println(“SQLException: ” + ex.getMessage());

}

注意有几个地方是你需要修改的。

url和账号，密码需要与你自己的相一致。

这些需要访问的数据必须要与数据库中的类型相互匹配，才能打印出正确的结果。

右键单击工程名–>Build Path –>Configure Biuld Path –>Libraries –> Add External JARs –>加入一个jdbc包（具体请查考Mysql的简单使用（一））—>ok

这时，在包下会多了一个Referenced Libraries包文件，则说明配置已经成功。

点击Run as —> 运行Java Application —>JDBCTest–link—>

以上所述是如何在Java程序中访问mysql数据库中的数据并进行简单的操作的相关知识，希望对你有所帮助，

关于java连接mysql数据库实例的介绍到此就结束了，不知道你从中找到你需要的信息了吗？如果你还想了解更多这方面的信息，记得收藏关注本站。

香港服务器首选，2H2G首月10元开通。（）提供简单好用，价格厚道的香港/美国云服务器和独立服务器。IDC+ISP+ICP资质。ARIN和APNIC会员。成熟技术团队15年行业经验。