JAVA操作MySQL数据库
总体步骤:
1) 获取驱动(可以省略)
2) 获取连接
Connection 接口,代表一个连接对象 ,具体的实现类由数据库的厂商实现
使用 DriverManager类的静态方法,getConnection可以获取数据库的连接
3) 获取Statement对象
通过Connection 的 createStatement方法 获取sql语句执行对象
4) 处理结果集(只在查询时处理)
5) 释放资源
代码如下:
package jdbc;import java.sql.*;public class Test01 {public static void main(String[] args) throws ClassNotFoundException, SQLException {//使用驱动;Class.forName("com.mysql.jdbc.Driver");// 创建连接,涉及数据库IP,端口,数据库名,字符集,账号及密码String url = "jdbc:mysql://127.0.0.1:3307/testdb?characterEncoding=UTF-8";Connection conn = DriverManager.getConnection(url,"root","Root#123456");//System.out.println(conn);// 获取语句执行平台对象 StatementStatement smt = conn.createStatement();// 创建表 executeUpdate方法String sql1 = "create table if not exists test14(id int primary key auto_increment ,name varchar(20),age int);";smt.executeUpdate(sql1);// 插入数据String sql_i = "insert into test14 values(1,'刘备',45),(2,'关羽',40),(3,'张飞',37),(4,'赵云',30),(5,'诸葛亮',27);";smt.executeUpdate(sql_i);// 更新数据String sql_u= "update test14 set age = 36 where name='张飞';";smt.executeUpdate(sql_u);// 查询结果String sql_q = "select * from test14;";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();}}
结果如下:


2. mysql8.0新增用户及加密规则修改的那些事
3. 比hive快10倍的大数据查询利器-- presto
4. 监控利器出鞘:Prometheus+Grafana监控MySQL、Redis数据库
5. PostgreSQL主从复制--物理复制
6. MySQL传统点位复制在线转为GTID模式复制
评论
