转自:
下文笔者讲述使用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