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数据库中的数据并进行简单的操作
如何在Java程序中访问mysql数据库中的数据并进行简单的操作
/**
* 获取数据库的连接
* @return conn
*/
public static Connection getConnection() throws Exception{
String url = “jdbc:
String user = “opermain”;
String psw = “opermain”;
Connection conn = null;
PreparedStatement pstm = null;
ResultSet rs = null;
Class.forName(“com.mysql.jdbc.Driver”);
if(null == conn) {
try {
conn = DriverManager.getConnection(url, user, psw);
} catch (SQLException e) {
System.out.println(“获取失败”);
throw new RuntimeException(e);
} finally{
closeResources(conn,pstm,rs);
}
}
return conn;
}
/**
* 释放资源
* @param conn
* @param pstmt
* @param rs
*/
public static void closeResources(Connection conn,PreparedStatement pstmt,ResultSet rs) {
if(null != rs) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
throw new RuntimeException(e);
} finally {
if(null != pstmt) {
try {
pstmt.close();
} catch (SQLException e) {
e.printStackTrace();
throw new RuntimeException(e);
} finally {
if(null != conn) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
throw new RuntimeException(e);
}
}
}
}
}
}
}
////tuserrole执行插入
//try {
//String sql = “insert into sys_userrole(roleid,userid) values (?,?)”;
//conn = getConnection();
//conn.setAutoCommit(false);
//PreparedStatement pstmt = (PreparedStatement) conn.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);//传入参数:Statement.RETURN_GENERATED_KEYS
//pstmt.setInt(1, 5);
//pstmt.setInt(2, sid);
//pstmt.executeUpdate();
//ResultSet rs = pstmt.getGeneratedKeys(); //获取结果
//int a = -1;
//if (rs.next()) {
//a = rs.getInt(1);//取得ID
//}
//System.out.println(a);
//System.out.println(“t_userrole执行成功”);
//conn.commit();
//} catch (Exception e) {
//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数据库实例的介绍到此就结束了,不知道你从中找到你需要的信息了吗 ?如果你还想了解更多这方面的信息,记得收藏关注本站。