12 月3号(第29、30、31天的学习)

处理数据库

//调用包
import java.sql.*;

/**
*  ChangaClass 类
* @author xinjie
*
*/
public class ChangeClass {

/**
* getUserName() 方法
* @param String connString
* @param String SQLString
* @return returnVales
* @throws SQLException
*/
public boolean change(String connString, String SQLString){

    //定义参数
boolean returnValue = false;

    //如果出现异常
    try {
    Connection connection = DriverManager.getConnection(connString,"root", "root");
   
    //调用创建声明
        Statement statement = connection.createStatement();
       
        // int类型i调用SQL代码
        int i = statement.executeUpdate(SQLString);
       
        // 如果i大于0，表示插入成功
        if (i > 0) returnValue = true;
       
        //关闭statement
        statement.close();
           
        //关闭connection
        connection.close();
       
    //如果出现异常在这进行捕捉
    } catch (SQLException e ) {
   
    //返回值等于否
    returnValue = false;
   
    //不管有没有出现异常会后在会进入这里走一遍
    } finally {
    
    }
   
    return returnValue;
}       
}

数据库的驱动路径
package JDBC;

/**
*  DriverClass 类
*  @author xinjie
*
*/
public class DriverClass {

/**
* Driver() 方法
* @return connSreing
*/
public String Driver(){

//定义连接字符串
String connString = "jdbc:mysql://localhost/ace?useUnicode=true&characterEncoding=utf-8";

return connString;
}
}

数据库的更新

package JDBC;

/**
* JdbcUpdate 类
* @author xinjie
*
*/
public class JdbcUpdate {

/**
* main() 主方法
* @param String[] agrs
* return 空
*/
public static void main(String[] agrs){

//定义SQL语句
String SQLString = "UPDATE users SET user_name = 'chenmimimi'  WHERE user_name = 'chenmihua' ;";

// 调用改变类
ChangeClass change = new ChangeClass();

// 调用驱动类
DriverClass update = new DriverClass();

//update调用Driver方法 赋值给String类型connSreing
String connString = update.Driver();

//if语句
if (change.change(connString, SQLString )){

//输出
System.out.println("更新成功！");

//否
}else{

//输出
System.out.println("更新失败！");
}


}
}

数据库的删除

/**
* JdbcDelete 类
* @author xinjie
*
*/
public class JdbcDelete {

/**
* main() 主方法
* @param String[] agrs
* return 空
*/
public static void main(String[] agrs){

//定义SQL语句
String SQLString = "DELETE FROM  users WHERE user_name = 'luyufeng'"; 

// 调用类
ChangeClass change = new ChangeClass();

// 调用类
DriverClass conn = new DriverClass();

//conn调用Driver方法 赋值给String类型connSreing
String connString = conn.Driver();

//if语句
if (change.change(connString, SQLString)){

//输出
System.out.println("删除成功！");

//否
}else{

//输出
System.out.println("删除失败！");
}
}
}

插入

/**
* JdbcInsert 类
* @author xinjie
*
*/
public class JdbcInsert {

/**
* main() 方法
* @param Sreing[] agrs
* return 空
*/
public static void main(String[] agrs){

//定义SQL语句
String SQLString = "INSERT INTO users (user_id,user_name,password,age,sex,binrthday)" + 
   "VALUES(106,'chenmihua',14,56,'n','1956-01-01'); ";

// 调用类
ChangeClass change = new ChangeClass();

//调用类
DriverClass conn = new DriverClass();

//conn调用Driver方法 赋值给String类型connSreing
String connString = conn.Driver();

//if语句
if (change.change(connString, SQLString)){

//输出
System.out.println("插入成功！");

//否
}else{

//输出
System.out.println("插入失败！");
}
}
}

数据库的查询处理数据库

package JDBC;

//调用包
import java.sql.*;

/**
* Jdbc 类
* @author xinjie
*
*/
public class Jdbc {

/**
* getUserName() 方法
* @param String connString
* @param String SQLString
* @return getUserName
* @throws SQLException
*/
public String[] getUserName(String connString, String SQLString) throws SQLException {

//定义接受驱动字符串
    Connection connection = DriverManager.getConnection(connString,"root", "root");
   
    //如果出现异常
    try {
   
    //调用创建声明
        Statement statement = connection.createStatement();
       
        //获得SQL语句
        ResultSet rs = statement.executeQuery(SQLString);
       
        //定义参数
        int rowcount = 0;
       
        //定义参数
        int i = 0;
       
        //if语句
        if( rs.last()) {
       
        //引用
             rowcount = rs.getRow();
            
             //调用方法
             rs.beforeFirst();
        }
       
        //创建实例化对象
        String[] retArray = new String[rowcount];
       
        //循环rsx下一个
        while (rs.next()) {
       
        //数组i+1等于rs获得数组类型user_name
            retArray[i++] = rs.getString("user_name");
           
        }
       
        //关闭statement
        statement.close();
       
        //返回 retArray
        return retArray;
       
    //如果出现异常在这进行捕捉
    } catch (SQLException e ) {
   
   
        //System.err.print("SQLException: ");
        //System.err.println(e.getMessage());
   
    //不管有没有出现异常会后在会进入这里走一遍
    } finally {
    
    }
   
    //返回值为空
    return null;
}       
}

查询数据库的操作方法

//引用包
import java.sql.*;

/**
* JdbcSelect 类
* @author xinjie
*
*/
public class JdbcSelect {

/**
* main() 主方法
* @param String[] agrs
* return 空
*/
public static void main(String[] agrs){

//定义连接字符串
String connString = "jdbc:mysql://localhost/ace?useUnicode=true&characterEncoding=utf-8";

//定义SQL语句
String SQLString = "SELECT user_name FROM users";

//  调用类
jdbcyouhuo1 jb1 = new jdbcyouhuo1();

//如果出现异常
try{

//获得连接
String[] rs = jb1.getUserName(connString, SQLString);

  //创建实例化对象
for (int i=0;i<rs.length;i++){

//调用方法
System.out.println(rs[i]);
}


// 输出结果
} catch(Exception e) {

//在这里捕捉
e.printStackTrace();
}
}
}