Java连接MySQL数据库并进行简单查询

Java连接MySQL数据库并进行简单查询 2022-08-31 924

数据库操作流程图：

一、连接准备

1、配置好MySQL环境并建立数据库；

2、配置好Java环境，准备有一编辑器（该文章以eclipse为例）

3、下载连接包并将其加载在自己的项目中：mysql-connector-java-8.0.29.jar（版本依照自己的MySQL）

4、自己创建一个数据库并建立一个表供自己检验

（我创建了一个kkk数据库并建立了有id与name属性的one表，内容如下图：）

二、代码编写

1、准备所需的String内容：

//加载驱动所需
	private static final String driver = "com.mysql.cj.jdbc.Driver";
	//建立连接所需
	private static final String con_url = "jdbc:mysql://localhost:3306/kkk?useSSL=false&serverTimezone=UTC";
	private static final String	user_name = "root";
	private static final String user_passward = "123456";

2、静态代码块加载驱动；

/**
	 * 1、静态代码块加载驱动，因为
	 * 只需要运行一次
	 */
	static {
		try {
			Class.forName(driver);
            System.out.println("加载驱动成功！");
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

3、创建连接：

/**
	 * 2、建立连接
	 * @return
	 * @throws SQLException
	 */
	protected static Connection getConnecter() throws SQLException {
		Connection con = null;
		con = DriverManager.getConnection(con_url, user_name, user_passward);
		System.out.println("获取连接成功！");
		return con;
	}

4、准备语句：

Statement stmt = con.createStatement();
    String sql = "select * from one";

5、执行操作：

ResultSet rs = stmt.executeQuery(sql);

6、处理结果：

//处理结果集
        List<String> res = new ArrayList<String>();
		while(rs.next()) {
			String str = new String();
			str = rs.getString("name");
			res.add(str);
		}

7、回收资源：

rs.close();
        System.out.println("结果集关闭成功！");
		stmt.close();
		System.out.println("语句通道关闭成功！");
		con.close();
        System.out.println("关闭连接成功！");

8、结果输出：

List<String> str = null;
		try {
			str = dataQuery();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		//遍历输出
		if(str!=null){
			for(String out:str) {
				System.out.println(out);
			}
		}