java连接mysql实验-CFANZ编程社区

1、安装环境 1）、安装mysql 解压mysql压缩包，并在mysql的根目录下创建一个data文件夹和一个my.ini配置文件。图片.png 其中my.ini配置为：

[mysql]
# 设置mysql客户端默认字符集
default-character-set=utf8
[mysqld]
#设置3306端口port = 3306

# 设置mysql的安装目录
basedir=E:/javaweb/config/mysql-8.0.32-winx64/mysql-8.0.32-winx64

# 设置mysql数据库的数据的存放目录
datadir=E:/javaweb/config/mysql-8.0.32-winx64/mysql-8.0.32-winx64/data

# 允许最大连接数
max_connections=200

# 服务端使用的字符集默认为8比特编码的latin1字符集
character-set-server=utf8

# 创建新表时将使用的默认存储引擎
default-storage-engine=innodb

2）、配置数据库环境变量系统环境变量中添加：变量名：MYSQL_HOME 变量值：mysql的根目录图片.png Path中添加一个变量：%MYSQL_HOME%\bin 3）、安装数据库 a、初始化mysql 以管理员身份打开终端，输入命令:mysqld --initialize-insecurer 如果mysql根目录下生成了data目录，那么就初始化成功了。 b、安装mysql服务打开cmd，输入命令：mysqld install c、启动mysql服务在以管理员身份运行cmd中输入命令： Net start mysql #启动mysql服务 Net stop mysql #关闭mysql服务图片.png 这样就完成了mysql的安装与配置。 4）、安装navicat便于管理数据库内容创建一个自己的数据库。 2、创建项目，项目下创建两个类 JDBCUtil类：（该类用于连接数据库）

package lrhJDBCUtilProject;

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

public class JDBCUtil {
private static Connection conn;

public static Connection getConnection() {
try {
// 加载数据库驱动类
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
e.printStackTrace();
}

try {
if (conn == null || conn.isClosed()) {
conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/surplk", "root", "");
}
} catch (SQLException e) {
e.printStackTrace();
}

return conn;
}
}

DaoTest类：（该类用于操作数据库）

package lrhJDBCUtilProject;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class DaoTest {
public static void main(String[] args) {
//调用JDBCUtil类中的连接数据库操作
Connection conn = JDBCUtil.getConnection();
PreparedStatement ps = null;
ResultSet rs = null;
//用数组sql存入数据库操作，向jdbc_test表中插入数据
String[] sql = {
"insert into jdbc_test(id,name) values(1,'tom')",
"insert into jdbc_test(id,name) values(2,'lk')",
"insert into jdbc_test(id,name) values(3,'jereh')"
};
String tableSql = "create table jdbc_test(id int not null primary key, name varchar(255) not null)";

try {
//创建新表-jdbc_test
ps = conn.prepareStatement(tableSql);
ps.executeUpdate();
//用循环语句依次插入数据
for (int i = 1; i < sql.length+1; i++) {
ps = conn.prepareStatement(sql[i-1]);
int count = ps.executeUpdate();
if (count > 0) {
System.out.println("第"+i+"次插入返回1条结果>>>successfuly:"+ sql[i-1]);
} else {
System.out.println("第"+i+"次插入返回1条结果>>>error:"+ sql[i-1]);
}
}

System.out.println("--- 数据库查询结果 ---");
System.out.println("id\tname");
System.out.println("--------------------");

ps = conn.prepareStatement("SELECT id,name FROM jdbc_test");
rs = ps.executeQuery();
//打印表中内容，查看是否写入成功
while (rs.next()) {
int id = rs.getInt(1);
String name = rs.getString(2);
System.out.println(id + "\t" + name);
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
//释放连接
if (rs != null) {
rs.close();
}
if (ps != null) {
ps.close();
}
if (conn != null) {
conn.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}

需创建一个lib然后导入mysql-connector-java-5.1.49-bin.jar 图片.png 之后就可以执行了。执行结果：在navicat中刷新查看