文件名称:jdbc连接代码
文件大小:4KB
文件格式:JAVA
更新时间:2018-12-15 10:03:06
jbdc
这个是一个连接MySQL数据库的操作类 public class MyJdbc { public static void main(String[] args) { // register(); display(); } private static void display() { // 定义链接字符串 String connectionString = "jdbc:mysql://localhost:3306/blog?user=root&password=root"; // 定义驱动数据库的类 String driver = "org.gjt.mm.mysql.Driver"; // 定义连接数据库对象conn Connection conn = null; // 定义执行sql语句对象stmt Statement stmt = null; //定义结果集对象rs,用来保存查询的结果 ResultSet rs = null; try { // 通过反射加载驱动程序类 Class.forName(driver).newInstance(); // Connection作用是连接数据库 conn = DriverManager.getConnection(connectionString); String sql = "select * from userinfo"; // Statement作用是向数据库中发送sql语句,并告诉数据库执行sql语句,还要让数据库返回执行的结果 stmt = conn.createStatement(); // 向数据库中发送sql,并执行,获取执行结果 rs = stmt.executeQuery(sql); //获取结果集架构信息(有多少列,每列叫什么名字) ResultSetMetaData rsm = rs.getMetaData(); for (int i = 1; i <= rsm.getColumnCount(); i++) { System.out.print(rsm.getColumnName(i)); System.out.print("\t"); } System.out.println(); while(rs.next()){ System.out.print(rs.getInt("userid")); System.out.print("\t"); System.out.print(rs.getString("loginId")); System.out.print("\t"); System.out.print(rs.getString("loginPwd")); System.out.print("\t"); System.out.println(); } } catch (Exception e) { e.printStackTrace(); } finally { // 释放系统资源 try { if(rs!=null){ rs.close(); rs = null; } if (stmt != null) { stmt.close(); stmt = null; } if (conn != null) { conn.close(); conn = null; } } catch (SQLException e) { e.printStackTrace(); } } } private static void register() { Scanner input = new Scanner(System.in); // 定义链接字符串 String connectionString = "jdbc:mysql://localhost:3306/blog?user=root&password=root"; // 定义驱动数据库的类 String driver = "org.gjt.mm.mysql.Driver"; // 定义连接数据库对象conn Connection conn = null; // 定义执行sql语句对象stmt Statement stmt = null; try { // 通过反射加载驱动程序类 Class.forName(driver).newInstance(); // Connection作用是连接数据库 conn = DriverManager.getConnection(connectionString); // 定义sql语句 System.out.println("请输入用户名"); String loginId = input.next(); System.out.println("请输入密码"); String loginPwd = input.next(); StringBuffer sqlbuffer = new StringBuffer(); sqlbuffer .append("INSERT INTO UserInfo (loginId,loginPwd) VALUES('"); sqlbuffer.append(loginId); sqlbuffer.append("','"); sqlbuffer.append(loginPwd); sqlbuffer.append("')"); String sql = sqlbuffer.toString(); // String sql ="INSERT INTO UserInfo (loginId,loginPwd) VALUES('"+ // loginId +"','"+loginPwd+"')"; // Statement作用是向数据库中发送sql语句,并告诉数据库执行sql语句,还要让数据库返回执行的结果 stmt = conn.createStatement(); // 向数据库中发送sql,并执行,获取执行结果 int i = stmt.executeUpdate(sql); if (i > 0) { System.out.println("注册成功"); } else { System.out.println("注册失败"); } } catch (Exception e) { e.printStackTrace(); } finally { // 释放系统资源 try { if (stmt != null) { stmt.close(); stmt = null; } if (conn != null) { conn.close(); conn = null; } } catch (SQLException e) { e.printStackTrace(); } } } }