JDBC高级工具类以及增删改查的操作代码,Java代码库,德仔网

代码语言
代码分类
【Java】 JDBC高级工具类以及增删改查的操作
作者:旦朵 / 发布于2016/3/15/ 678
package cn.itcast.jdbc;
 
import java.lang.annotation.Target;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Scanner;
 
import javax.activation.MailcapCommandMap;
 
import org.junit.Test;
 
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Driver;
 
public class jdbc {
 
     
    public static void  query(String tableName) throws Exception{
        //注册驱动
        //创建数据库连接对象
         java.sql.Connection connection=jdbcutils.getConnection("checked","root","1234");
         //执行的数据库语句
         String sql="select * from "+tableName+"where deptId=?";
         //防止sql注入机制
          PreparedStatement sta = connection.prepareStatement(sql);
         //给需要的字段变量进行赋值 1.代表占位符的位置 2， 第二个代表该字段进行赋值
          sta.setInt(1,1);
        //执行操作语句
         ResultSet query = sta.executeQuery();
         while (query.next()) {
             
            int id=query.getInt("deptId");
            String name=query.getString("deptName");
            String adress=query.getString("address");
            System.out.println("id:"+id+"\t name:"+name+"\t adress:"+adress);
        }
 
    }
     
     public static void  insert(String tableName) throws Exception{
        //注册驱动
        //创建数据库连接对象
         java.sql.Connection connection=jdbcutils.getConnection("checked","root","1234");
         //执行的数据库语句
          String sql="insert into "+tableName+" values(?,?,?)";
         //防止sql注入机制
          PreparedStatement sta = connection.prepareStatement(sql);
         //给需要的字段变量进行赋值 1.代表占位符的位置 2， 第二个代表该字段进行赋值 
          sta.setInt(1, 60);//设置deptId的值
          sta.setString(2, "CEO");//设置职位
          sta.setString(3, "JAPAN");//工作地址
          int row = sta.executeUpdate();
            if(row>0){
            System.out.println("添加成功！");
             }
            else{
            System.out.println("添加失败！");
            }
        }
     public static void  delete(String tableName) throws Exception{
            //注册驱动
            //创建数据库连接对象
            java.sql.Connection connection=jdbcutils.getConnection("checked","root","1234");
            String sql="delete from "+tableName+" where deptId=?";       
             //防止sql注入机制
            PreparedStatement sta = connection.prepareStatement(sql);
            //deptId 进行赋值
            sta.setInt(1, 60);
            //返回值是对其数据库影响的值
            int row = sta.executeUpdate();
                if(row>0){
                System.out.println("删除成功！");
                 }
                else{
                System.out.println("删除失败！");
                }
            }
      
     public static  void update(String tableName) throws Exception{
            //注册驱动
            //创建数据库连接对象
            //创建操作对象
            java.sql.Connection connection=jdbcutils.getConnection("checked","root","1234");
            //执行的sql语句 
            String sql="update "+tableName+" set address=? where deptId=?";
            //防止sql注入
             PreparedStatement sta= connection.prepareStatement(sql);
             //给需要的字段值进行赋值
             sta.setString(1,"北京");
             sta.setInt(2,60);
            //
             int row = sta.executeUpdate();
                if(row>0){
                System.out.println("修改成功");
                 }
                else{
                System.out.println("修改失败");
                }
            }
    public static void main(String[] args) throws Exception {
         
        //做一个增删改查的操作数据库的驱动的工具类
         
        System.out.println("-----1.添加操作\t\t2.修改操作\t\t3.删除操作\t\t4.查询操作-----");
        System.out.println("请你输入你要操作的功能号码：");
        Scanner scanner=new Scanner(System.in);
        int i = scanner.nextInt();
        switch(i){
            case 1:jdbc.insert("dept");//添加
                   System.out.println("--------------");
                   break;
            case 2:jdbc.update("dept");//修改
                   System.out.println("--------------");
                   break;
            case 3:jdbc.delete("dept");//删除
                   System.out.println("--------------");
                   break;
            case 4:jdbc.query("dept");//查询
                   System.out.println("--------------");
                   break;
           default :System.out.println("输入操作有误"); 
                   break;
        }   
    }
}









package cn.itcast.jdbc;
 
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
 
import org.omg.PortableInterceptor.USER_EXCEPTION;
 
import com.mysql.jdbc.Driver;
 
public class jdbcutils {
 
    private  jdbcutils(){}//私有构造方法 并且直接用该类调用方法
    static{
        try {
            //注册驱动
            Class.forName("com.mysql.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    //注册的连接对象的 需要的参数的  databaseName是数据库的名字  userName数据库登录的用户名  String password 数据库的登陆的密码
    public static Connection getConnection(String databaseName,String userName ,String password)  throws Exception{
        //注册驱动
     
        String url="jdbc:mysql:///"+databaseName;
         
        //创建连接对象
        Connection connection=DriverManager.
                getConnection(url, userName, password);
        return connection;
    }
 
}
试试其它关键字
同语言下
可能有用的
旦朵贡献的其它代码(7)