java基础集合框架基础 增删改查中 ”改“的代码

2025-04-16 15:04:46
推荐回答(1个)
回答1:

网上截取的一段改的代码,包括连接mysql数据库,希望能帮到你。!


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

public class Dao {
private Connection conn = null;
PreparedStatement statement = null;

void connSQL() {
String url = "jdbc:mysql://localhost:3306/test?characterEncoding=UTF-8"; // 数据库地址,端口,数据库名称,字符集
String username = "root"; // 数据库用户名
String password = "root"; // 数据库密码
try {
Class.forName("com.mysql.jdbc.Driver"); // 加载驱动,必须导入包mysql-connector-java-5.1.6-bin.jar
conn = DriverManager.getConnection(url, username, password);
}
// 捕获加载驱动程序异常
catch (ClassNotFoundException cnfex) {
System.err.println("装载 JDBC/ODBC 驱动程序失败。");
cnfex.printStackTrace();
}
// 捕获连接数据库异常
catch (SQLException sqlex) {
System.err.println("无法连接数据库");
sqlex.printStackTrace();
}
}

// 关闭数据库
void deconnSQL() {
try {
if (conn != null)
conn.close();
} catch (Exception e) {
System.out.println("关闭数据库异常:");
e.printStackTrace();
}
}

 boolean updateSQL(String sql) {

        try {    

            statement = conn.prepareStatement(sql);    

            statement.executeUpdate();    

            return true;    

        } catch (SQLException e) {    

            System.out.println("更新数据库时出错:");    

            e.printStackTrace();    

        } catch (Exception e) {    

            System.out.println("更新时出错:");    

            e.printStackTrace();    

        }    

        return false;    

    }    

 void print(ResultSet rs) {

        System.out.println("-----------------");    

        System.out.println("查询结果:");    

        System.out.println("-----------------");    

     

        try {    

            while (rs.next()) {    

                System.out.println(rs.getInt(0) + "/t/t" + rs.getString(1)    

                        + "/t/t" + rs.getString(2));    

            }    

        } catch (SQLException e) {    

            System.out.println("显示时数据库出错。");    

            e.printStackTrace();    

        } catch (Exception e) {    

            System.out.println("显示出错。");    

            e.printStackTrace();    

        }    

    }    

 public static void main(String args[]) {

     

        Dao dao = new Dao();    

        dao.connSQL(); // 连接数据库    

        String s = "select * from users";    

 String update = "update users set userPWD =20000 where userID= '10000'";

 if (dao.updateSQL(update) == true) {

            System.out.println("更新成功");    

            ResultSet resultSet = dao.selectSQL(s);    

            dao.print(resultSet);    

        }    

 dao.deconnSQL(); // 关闭数据库连接

    }    

}    



来源地址:http://yuncode.net/code/c_50443e960251215