java（10）：jdbc的简单使用和操作

日期：2017/10/31
 使用JDBC访问数据库的步骤很简单，下面以MYSQL为例：

      1. 加载JDBC驱动器：将JDBC驱动（jar包）添加到java过程的lib文件夹中，然后将其配置构建路径也就是导入库;而在开发javaEE的web应用开发时，则要把目标数据库产品的jdbc驱动复制到WEB - INF/lib下；

      2. 加载JDBC驱动：Class. forName(driver)；

      3. 简历数据库连接：Connection con = null; 

                               
       con = DriverManager.getConnection(url,user,password);

      4. 建立Statement对象 or PreparedStatement对象：stmt = con. createStatement();

      5. 执行SQL语句：stmt.excute("insert into Employee values(1,'James',35)");

                   
                stmt.excute("insert into Employee values(2,'Tom',35)");

      6. 访问结果返回集ResultSet对象：rs = stmt.executeQuery("select * from Employee");

             
                                         
      while (rs.next()){

       
                                         
                            System.out.print(rs.getInt(1)); 
                                        
             
                                     
                                         
            }

      7. 将ResultSet、Statement、PreparedStatement、Connection对象关闭，释放资源：rs.close();
stmt.close() con.close();

 代码如下：

package com.java.sql;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class MysqlTestOne {
/**
* @SuppressWarnings 批注允许您选择性地取消特定代码段（即，类或方法）中的警告。
* 其中的想法是当您看到警告时，您将调查它，如果您确定它不是问题， 您就可以添加一个 @SuppressWarnings 批注，以使您不会再看到警告。
* */
@SuppressWarnings("resource")
public static void main(String [] args) throws Exception{
String user = "root";
String password = "";
String url = "jdbc:mysql://localhost:3306/test";
String driver = "com.mysql.jdbc.Driver";
Connection con = null;
Statement stmt = null;
ResultSet rs = null;
try{
Class. forName(driver);//加载驱动，Class.forName
con = DriverManager.getConnection(url, user, password);//建立连接
stmt = con.createStatement();//建立statement对象
stmt.execute("create table classtable(classmateId int NOT NULL AUTO_INCREMENT ,"//执行SQL语句
+ "name char(20) NOT NULL,"
+ "sex char(8) NOT NULL,"
+ "birthdate int NOT NULL,"
+ "address char(20) NOT NULL,"
+ "phonenumber int NOT NULL,"
+ "PRIMARY KEY (classmateId)"
+ ")ENGINE=InnoDB;");
// stmt.execute("select * from class ;");
// stmt.execute("insert into Employee values(3,'James1 ',2)");
// stmt.execute("insert int Employee values(2,'James2 ',26)");
rs = stmt. executeQuery("select * from classtable");//获取ResultSet
while(rs.next()){
System.out.println("Before**");
System.out.println(rs.getInt(1)+" "+rs.getString(2)+" "+rs.getString(3)+" "+rs.getInt(4)+" "+rs.getString(5)+" "+rs.getInt(6));
}
stmt.execute("INSERT INTO classtable (classmateId,name,sex,birthdate,address,phonenumber)"
+ "VALUES(1,'mmb','male',19941123,'maoming',123456),"
+ "(2,'lhm','male',19941023,'guangdong',123616), "
+ "(3,'hzt','female',19951193,'zhanjiang',1246456),"
+ "(4,'Dhm','male',19941023,'guangdong',123616),"
+ "(5,'DDm','male',19641023,'guangdong',123631);");
//内存泄露
rs = stmt. executeQuery("select * from classtable;");
while(rs.next()){
System.out.println("After**");
System.out.println(rs.getInt(1)+" "+rs.getString(2)+" "+rs.getString(3)+" "+rs.getInt(4)+" "+rs.getString(5)+" "+rs.getInt(6));
}

}
catch(SQLException e1){
e1. printStackTrace();
}finally{
try{
if(rs != null) rs.close();
if(stmt != null) stmt.close();
if(con != null) con.close();
}catch(SQLException e){
System.out.println(e. getMessage());
}
}
}
}