下面是Java基于JDBC连接MySQL数据库操作的完整攻略,包含两条示例。
步骤一:准备工作
在开始Java程序连接MySQL数据库之前,需要完成以下几个准备工作:
- 安装MySQL数据库并创建需要操作的数据库和表
- 下载并安装Java JDK
- 下载并安装MySQL Connector/J驱动程序
步骤二:创建数据库连接
请按照以下步骤创建数据库连接:
- 加载MySQL Connector/J驱动程序
Class.forName("com.mysql.jdbc.Driver");
- 创建数据库连接
String url = "jdbc:mysql://localhost:3306/mydatabase";
String username = "admin";
String password = "admin123";
Connection conn = DriverManager.getConnection(url, username, password);
其中,url
是要连接的数据库URL,mydatabase
是需要操作的数据库名称;username
和password
是连接MySQL数据库的用户名和密码。
步骤三:执行SQL语句
请按照以下步骤执行SQL语句:
- 创建Statement对象
Statement stmt = conn.createStatement();
- 执行SQL语句
String sql = "SELECT * FROM mytable";
ResultSet rs = stmt.executeQuery(sql);
其中,mytable
是需要操作的表名。
示例一:查询数据并输出
public class QueryDataDemo {
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
try {
// 加载MySQL Connector/J驱动程序
Class.forName("com.mysql.jdbc.Driver");
// 创建数据库连接
String url = "jdbc:mysql://localhost:3306/mydatabase";
String username = "admin";
String password = "admin123";
conn = DriverManager.getConnection(url, username, password);
// 创建Statement对象并执行SQL语句
stmt = conn.createStatement();
String sql = "SELECT * FROM mytable";
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 + ", name:" + name + ", age:" + age);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
// 关闭ResultSet、Statement和Connection
try { if (rs != null) rs.close(); } catch (Exception e) {}
try { if (stmt != null) stmt.close(); } catch (Exception e) {}
try { if (conn != null) conn.close(); } catch (Exception e) {}
}
}
}
示例二:插入数据
public class InsertDataDemo {
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
try {
// 加载MySQL Connector/J驱动程序
Class.forName("com.mysql.jdbc.Driver");
// 创建数据库连接
String url = "jdbc:mysql://localhost:3306/mydatabase";
String username = "admin";
String password = "admin123";
conn = DriverManager.getConnection(url, username, password);
// 创建Statement对象并执行SQL语句
stmt = conn.createStatement();
String sql = "INSERT INTO mytable(id, name, age) VALUES(1, '张三', 20)";
int rows = stmt.executeUpdate(sql);
// 输出插入数据的行数
System.out.println(rows + " rows affected.");
} catch (Exception e) {
e.printStackTrace();
} finally {
// 关闭Statement和Connection
try { if (stmt != null) stmt.close(); } catch (Exception e) {}
try { if (conn != null) conn.close(); } catch (Exception e) {}
}
}
}
以上两条示例演示了如何使用Java基于JDBC连接MySQL数据库进行数据查询和数据插入。需要注意的是,在实际应用中,还需要进行异常处理以及资源释放等操作。
本站文章如无特殊说明,均为本站原创,如若转载,请注明出处:Java基于jdbc连接mysql数据库操作示例 - Python技术站