MySQL java连接mysql数据库的代码

MySQL是一种关系型数据库管理系统，它提供了一种将数据存储在表中并使用结构化查询语言（SQL）进行检索和管理的方法。而Java是一种通用的、面向对象的计算机编程语言，由于其在企业级应用开发中的优势，被广泛应用于与数据库的交互。

在本文中，我们将详细介绍使用Java连接MySQL数据库的代码。首先，需要确保已正确安装并配置了MySQL数据库和Java开发环境。

1. 导入相关的Java库

在编写Java代码之前，我们需要导入与MySQL数据库连接相关的Java库。常用的库包括java.sql和com.mysql.jdbc。

import java.sql.DriverManager;
import java.sql.Connection;
import java.sql.SQLException;

2. 建立数据库连接

在Java中，我们使用Connection类来建立与数据库的连接。首先，需要提供数据库的连接URL、用户名和密码。

public class MySQLJDBCExample {
   static final String DB_URL = "jdbc:mysql://localhost/your_database";
   static final String USER = "your_username";
   static final String PASS = "your_password";

   public static void main(String[] args) {
      Connection conn = null;
      try {
         conn = DriverManager.getConnection(DB_URL, USER, PASS);
         System.out.println("成功连接到数据库");
      } catch (SQLException e) {
         System.out.println("数据库连接失败：" + e.getMessage());
      } finally {
         try {
            if (conn != null) {
               conn.close();
            }
         } catch (SQLException e) {
            System.out.println("关闭数据库连接失败：" + e.getMessage());
         }
      }
   }
}

在上述代码中，我们通过DriverManager.getConnection()方法来创建一个数据库连接对象conn。如果连接成功，则打印出”成功连接到数据库”的信息；如果连接失败，则打印出错误信息。

请注意，需要将localhost替换为数据库的主机名或IP地址，your_database替换为要连接的数据库名称，your_username和your_password替换为数据库的用户名和密码。

3. 执行SQL查询

连接到数据库后，我们可以使用Connection对象来执行SQL查询。下面的示例代码演示了如何执行一个简单的查询，并打印出查询结果。

import java.sql.DriverManager;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class MySQLJDBCExample {
   static final String DB_URL = "jdbc:mysql://localhost/your_database";
   static final String USER = "your_username";
   static final String PASS = "your_password";

   public static void main(String[] args) {
      Connection conn = null;
      Statement stmt = null;
      try {
         conn = DriverManager.getConnection(DB_URL, USER, PASS);
         stmt = conn.createStatement();
         String sql;
         sql = "SELECT id, name, age FROM employees";
         ResultSet rs = stmt.executeQuery(sql);

         while (rs.next()) {
            int id = rs.getInt("id");
            String name = rs.getString("name");
            int age = rs.getInt("age");

            System.out.println("ID: " + id);
            System.out.println("Name: " + name);
            System.out.println("Age: " + age);
            System.out.println("==================");
         }
         rs.close();
      } catch (SQLException e) {
         System.out.println("数据库查询失败：" + e.getMessage());
      } finally {
         try {
            if (stmt != null) {
               stmt.close();
            }
            if (conn != null) {
               conn.close();
            }
         } catch (SQLException e) {
            System.out.println("关闭数据库连接失败：" + e.getMessage());
         }
      }
   }
}

在上述代码中，我们使用conn.createStatement()方法创建一个Statement对象，用于发送SQL查询。然后，我们执行一个简单的SELECT查询，并使用rs.next()和rs.getInt()等方法来获取查询结果。

请确保将employees替换为实际的表名，其中包含id、name和age等字段。

4. 插入和更新数据

除了查询操作外，我们还可以使用Java代码向MySQL数据库插入和更新数据。下面的示例代码演示了如何执行插入和更新操作。

import java.sql.DriverManager;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class MySQLJDBCExample {
   static final String DB_URL = "jdbc:mysql://localhost/your_database";
   static final String USER = "your_username";
   static final String PASS = "your_password";

   public static void main(String[] args) {
      Connection conn = null;
      Statement stmt = null;
      try {
         conn = DriverManager.getConnection(DB_URL, USER, PASS);
         stmt = conn.createStatement();

         // 插入数据
         String insertSql = "INSERT INTO employees (id, name, age) VALUES (1, 'John', 25)";
         stmt.executeUpdate(insertSql);
         System.out.println("插入数据成功");

         // 更新数据
         String updateSql = "UPDATE employees SET age = 30 WHERE id = 1";
         stmt.executeUpdate(updateSql);
         System.out.println("更新数据成功");
      } catch (SQLException e) {
         System.out.println("数据库操作失败：" + e.getMessage());
      } finally {
         try {
            if (stmt != null) {
               stmt.close();
            }
            if (conn != null) {
               conn.close();
            }
         } catch (SQLException e) {
            System.out.println("关闭数据库连接失败：" + e.getMessage());
         }
      }
   }
}

在上述代码中，我们使用stmt.executeUpdate()方法执行插入和更新操作。请确保将employees替换为实际的表名，并根据表的结构调整插入或更新的数据。