最近可能需要用到用java调用MySQL数据库，java提供了接口，打算赶紧学来用用！
软件使用：Eclipse。
下载
java连接MySQL需要驱动包，所以需要下载jar包。网上各处都有提供.
一般长这样
mysql-connector-java-5.1.38.jar
配置
1.新建一个项目，在自己的项目新建一个文件夹（用来存储jar包）
将自己下载的jar包直接拖入这个文件夹就行了。
2.接下来在项目下右键选择Configure Build Path
image
3.选择Libraries下的Add JARS...找到下载的jar包，完成！
image
使用
首先import sql包
import java.sql.*;
在自己本身MySQL有一个数据库后
image
我们创建一些初始数据
/*
MySQL的JDBC URL编写方式:
jdbc:mysql://主机名称:连接端口/数据库名称?参数=值
为了避免中文乱码要设置"characterEncoding=utf8"
*/
//创建数据库URL
static final String DB_URL = "jdbc:mysql://localhost:3306/test?characterEncoding=utf8&useSSL=true";
// 数据库的用户名与密码，需要根据自己的设置
static final String USER = "root";
static final String PASS = "root";
创建完，在主函数加载驱动程序及使用
public static void main(String[] args) {
Connection con = null;
//1. 注册 JDBC 驱动
Class.forName("com.mysql.jdbc.Driver");
System.out.println("成功加载MySQL驱动");
//2. 获得数据库连接
System.out.println("连接数据库...");
Connection conn = DriverManager.getConnection(DB_URL,USER,PASS);
System.out.println("成功连接数据库");
//3. 成功即可操作数据库，创建Statenment实例
Statement stmt = conn.createStatement();
// Statement里面带有很多方法，比如executeUpdate可以实现插入，更新和删除等
ResultSet rs = stmt.executeQuery("SELECT * FROM websites");
//4. 如果有数据，rs.next()返回true
while(rs.next()){
System.out.println(" 名称："+rs.getString("name")+" 地址："+rs.getString("url"));
}
}
最简单就是上面四个步骤，我分别解释了上面意思。
其实还需要有处理各种错误的情况，还有断开连接的函数。
让我们看看结果呈现上面吧
image
可见已经成功连接数据库，并且用sql语句调用数据库。
创建数据表并插入数据
public static void main(String[] args) {
Connection conn=null;
Statement stmt=null;
try {
//1.加载驱动程序
Class.forName("com.mysql.jdbc.Driver");
//2. 获得数据库连接
System.out.println("连接数据库...");
conn = DriverManager.getConnection(DB_URL, USER, PASS);
//3.操作数据库，实现增删改查
stmt = conn.createStatement();
String mysql;
mysql="create table student(NO char(20),name varchar(20),primary key(NO))";
//创建表格
int result=stmt.executeUpdate(mysql);
//在执行之后，查看受影响行数，返回-1代表不成功
if(result!=-1) {
System.out.println("创建students表格成功");
mysql = "insert into student(NO,name) values('2016001','haige')";
result= stmt.executeUpdate(mysql);
mysql = "insert into student(NO,name) values('2016002','Mr.chen')";
result= stmt.executeUpdate(mysql);
System.out.println("插入完成");
mysql = "select * from student";
ResultSet rs = stmt.executeQuery(mysql);
//执行查询语句看结果
System.out.println("学号\t姓名");
while(rs.next()){
String student_id=rs.getString(1);
String student_name =rs.getString(2);
System.out.println(student_id+"\t"+student_name);
}
rs.close();
stmt.close();
conn.close();
}
}catch (SQLException e) {
System.out.println("MySQL操作错误");
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
System.out.println("程序结束！");
}
以上我加入了try-catch是为了在错误时可以检测出错误的地方，可以不加。
还加入了close关闭数据库的连接的操作。
image
更新删除操作
//SQL语句
update student set name=? where NO='2016002'
现在对数据库进行更新删除操作
public static void main(String[] args) {
Connection conn=null;
Statement stmt=null;
try {
//1.加载驱动程序
Class.forName("com.mysql.jdbc.Driver");
//2. 获得数据库连接
System.out.println("连接数据库...");
conn = DriverManager.getConnection(DB_URL, USER, PASS);
//3.操作数据库，实现增删改查
stmt = conn.createStatement();
String mysql,mysql2,mysql3;
//更新操作
mysql="update student set name=? where NO='2016002'";
PreparedStatement pst=conn.prepareStatement(mysql);
pst.setString(1, "chenxx");
pst.executeUpdate();
System.out.println("更新为chenxx完成");
//删除操作
mysql2="delete from student where name=?";
pst = conn.prepareStatement(mysql2);
pst.setString(1, "haige");
pst.executeUpdate();
System.out.println("删除haige完成");
//查询操作
mysql3="select * from student";
ResultSet rs = stmt.executeQuery(mysql3);
System.out.println("查询完成");
//执行查询语句看结果
System.out.println("学号\t姓名");
while(rs.next()){
String student_id=rs.getString(1);
String student_name =rs.getString(2);
System.out.println(student_id+"\t"+student_name);
}
rs.close();
stmt.close();
conn.close();
}catch (SQLException e) {
System.out.println("MySQL操作错误");
e.printStackTrace();
}catch (Exception e) {
e.printStackTrace();
}
System.out.println("程序结束！");
}
image
很好，结果如我们所料！
现在暂时没啥问题，目前还只是基础，等到真正使用起来可能会有一些问题，到时候再记录下来吧！
-to be continue-
学习笔记
网友评论