目录
前言:
项目中导入驱动包
插入记录
创建数据源
连接数据库
构造sql语句
执行sql语句
释放资源
整体代码展示
查看数据
代码展示
小结:
前言:
MySQL为Java提供了驱动包。通过Java程序实现的客户端,可以通过这个驱动包,把客户端和MySQL服务器进行网络通信。
项目中导入驱动包
将驱动包下载好之后,直接复制到项目中的包中(我这里是lib包下)。然后点击下面的Add as Library导入到库中,之后就可以发现可以解析这个驱动包了,也就成功了。
插入记录
创建数据源
首先需要创建数据源,它是描述数据库服务器在哪里,然后才可以经过客户端进行连接服务器。
DataSource dataSource = new MysqlDataSource();
这里是构造了一个datasource对象。采取向上转型的方式。这样的好处是,如果使用不同的数据库,它所提供的驱动包也会不一致,那么我们只需要改动这一处代码就可以。
JDBC支持两种方式的风格。DriverManager和DataSource。DriverManager会利用反射的机制,并且它不支持重复连接,它会直接关闭物理连接。DataSource内置了数据库连接池,其中可以创建一定数量的数据库连接,并且支持重复连接,它只是回收了对象。这里介绍DataSource方式的风格。
jdbc:mysql://127.0.0.1:3306/test9?characterEncoding=utf8&useSSL=false
- jdbc:mysql这个是jdbc下的MySQL。
- 127.0.0.1特殊的ip地址,用来指向本电脑的ip,称为环回ip。只要服务器和客户端在同一个主机上就可以使用这个ip。
- 3306MySQL程序的端口号,默认是3306。
- test9数据库名。
- characterEncoding=utf8描述了请求的编码字符集,这里是utf8。
- useSSL=false关闭加密方式。
设置URL,用户名及密码
DataSource dataSource = new MysqlDataSource();
((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/test9?characterEncoding=utf8&useSSL=false");
((MysqlDataSource)dataSource).setUser("用户名");
((MysqlDataSource)dataSource).setPassword("密码");
注意:这里需要向下转型。创建数据源需要确定数据库的具体位置,及一些信息。
连接数据库
Connection connection = dataSource.getConnection();
注意:连接数据库是把这个客户端和服务器进行连接。这里要使用java.sql下的Connection。这里会抛异常,需要对异常进行处理。
构造sql语句
String sql = "insert into student values(1, 'aaa')";
String sql = "insert into student values(?,?)";//设置通配符
PreparedStatement statement = connection.prepareStatement(sql);//预处理
//替换通配符
statement.setInt(1, id);
statement.setString(2, name);
注意:
有两种方式构造sql语句。第一种是直接写出来。第二种是设置通配符,通过接下来对sql进行预处理,返回的对象来设置通配符里面的值。第一个?位置是1,第二个?位置是2以此类推。
这里使用PreparedStatement,优点是可以执行带或者不带参数的sql,sql语句会预编译在数据库系统,执行速度快于Statment对象。
执行sql语句
//执行sql语句,返回所影响的行数
int ret = statement.executeUpdate();
注意:执行插入,修改,删除时使用executeUpdate,查看记录使用executeQuery。插入时会返回所影响的行数。
释放资源
//释放资源,断开连接
statement.close();
connection.close();
注意:当进行资源的利用,就需要去释放相应的资源。不然就很有可能造成内存泄漏。释放资源时,需要释放其他资源最终断开连接。即释放资源和连接资源顺序是相反的。
整体代码展示
import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;
public class JDBCInsertDemo {
public static void main(String[] args) throws SQLException {
//先创建DateSource数据源,描述数据库服务器在哪
DataSource dataSource = new MysqlDataSource();
((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/test9?characterEncoding=utf8&useSSL=false");
((MysqlDataSource)dataSource).setUser("用户名");
((MysqlDataSource)dataSource).setPassword("密码");
Scanner scanner = new Scanner(System.in);
System.out.println("请输入学号:");
int id = scanner.nextInt();
System.out.println("请输入姓名:");
String name = scanner.next();
//建立连接
Connection connection = dataSource.getConnection();
//构造sql语句
//String sql = "insert into student values(" + id + " , '" + name + "')";
String sql = "insert into student values(?,?)";//设置通配符
//对sql语句进行预处理,jdbc 中还需要搭配一个特定的对象, 来描述这里的 sql 的情况
PreparedStatement statement = connection.prepareStatement(sql);
//替换通配符
statement.setInt(1, id);
statement.setString(2, name);
//执行sql语句,返回所影响的行数
int ret = statement.executeUpdate();
System.out.println(ret);
//释放资源,断开连接
statement.close();
connection.close();
}
}
查看数据
这里和插入记录的差别是在执行sql时使用的方法不同,返回的结果不同。插入记录使用的是executeUpdate返回的结果是所影响的行数,查看记录使用的是executeQuery返回查看结果集合。然后只需要遍历这个集合就可以看见所查询的记录。
注意:集合遍历时,是以行为单位进行遍历的。其中的参数填对应列的列名,方法就使用相对应的类型。
代码展示
import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class JDBCSelectDemo {
public static void main(String[] args) throws SQLException {
//创建数据源,描述数据库服务器位置
DataSource dataSource = new MysqlDataSource();
((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/test9?characterEncoding=utf8&useSSL=false");
((MysqlDataSource)dataSource).setUser("用户名");
((MysqlDataSource)dataSource).setPassword("密码");
//建立连接
Connection connection = dataSource.getConnection();
//构造sql,预处理
String sql = "select * from student";
PreparedStatement statement = connection.prepareStatement(sql);
//执行sql,返回结果集合
ResultSet resultSet = statement.executeQuery();
//遍历集合,打印数据
while(resultSet.next()) {
int id = resultSet.getInt("id");
String name = resultSet.getString("name");
System.out.println(id + " " + name);
}
//释放资源
resultSet.close();
statement.close();
connection.close();
}
}
小结:
JDBC编程为我们操作数据库带来了很大的遍历,需要我们掌握和使用它。