Java操作MySQL数据库
相关文件
MySQL驱动包
整体实现
public void demo(){
try {
//加载驱动
String driver = "com.mysql.cj.jdbc.Driver";
Class.forName(driver);
//获取连接
String url = "jdbc:mysql://localhost:3306/数据库名";
String user = "root", pwd = "123456";
Connection connection = DriverManager.getConnection(url,user,pwd);
//发送SQL语句
String sql = "insert into 表名 values(?,?);";
PreparedStatement statement = connection.prepareStatement(sql);
//设置语句内 ? 的值, 从 1 开始
statement.setString(1,"admin");
statement.setString(2,"password");
//返回受影响行数, 删除和修改修改sql内容就行了
int row = statement.executeUpdate();
//查询
sql = "select * from admin";
ResultSet resultSet = statement.executeQuery(sql);
//返回结果集, next()方法用于指向下一行,当指向行尾时返回false, 最初指向行首(注意:不是第一条数据)
while (resultSet.next()){
String name = resultSet.getString(1); // 1 为当前指向行的第一列数据
String password = resultSet.getString("pwd"); // 为当前指向行的 pwd 列
System.out.println("name=" + name + " pwd=" + password);
}
} catch (SQLException e) {
throw new RuntimeException(e);
} catch (ClassNotFoundException e) {
throw new RuntimeException(e);
}
}