转自:
下文笔者讲述使用java代码对一个MySQL数据库的操作方法分享,如下所示:
实现思路:
在操作前,需引入指定的jar包,
mysql-connector-java-8.0.26.jar
具体的操作流程
1.获取驱动(class.forName)
2.获取连接(DriverManager.getConnection)
返回一个Connection接口,即作为连接对象
3.获取Statement对象
使用Connection中的createStatement方法,可获取sql语句的执行对象
4.处理结果集(当有返回数据时)
5.释放资源(结果集,Statement对象,连接conn)
例:
java连接MySQL的示例分享
package com.java265.other;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
/*
* java265.com java连接mysql的示例分享
* */
public class mysqlSelect {
public static void main(String[] args) throws Exception {
//获取驱动;
// Class.forName("com.mysql.jdbc.Driver");
Class.forName("com.mysql.cj.jdbc.Driver");
//创建数据库连接(数据库IP,端口,数据库名,字符集,账号及密码)
String url = "jdbc:mysql://localhost:3306/test?characterEncoding=UTF-8";
//返回连接
Connection conn = DriverManager.getConnection(url, "root", "root");
//System.out.println(conn);
// 获取语句执行平台对象 Statement
Statement smt = conn.createStatement();
// 创建表 executeUpdate方法
String sql1 = "create table if not exists testTb(id int primary key auto_increment ,name varchar(120),age int);";
smt.executeUpdate(sql1);
// 插入数据
String sql_i = "insert into testTb values(1,'张三',123),(2,'王五',09),(3,'liuliu',88),(4,'曹操',6),(5,'场景胡',88);";
smt.executeUpdate(sql_i);
// 更新数据
String sql_u = "update testTb set age = 96 where name='aa';";
smt.executeUpdate(sql_u);
// 查询结果
String sql_q = "select * from testTb;";
ResultSet res = smt.executeQuery(sql_q);
while(res.next()){
int id = res.getInt(1);
String name= res.getString("name");
int age = res.getInt("age");
System.out.println("id:"+ id + " name:" + name +" age:"+age);
}
// 关闭流 (先开后关)
res.close();
smt.close();
conn.close();
}
}
---------运行以上代码,将输出以下信息------
com.mysql.cj.jdbc.ConnectionImpl@42d8062c
id:1 name:张三 age:123
id:2 name:王五 age:9
id:3 name:liuliu age:88
id:4 name:曹操 age:6
id:5 name:场景胡 age:88
