java如何连接Mysql数据库及进行增删改查操作

Posted 2022-11-28 测试小静静

一、 下载mysql驱动jar依赖包

 <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.18</version>
        </dependency>

二、将连接数据，添加到配置文件

 driverName=com.mysql.cj.jdbc.Driver

 dbURL=jdbc:mysql://数据库连接地址

 userName=数据库用户名

 userPwd=数据库用户密码

三、核心代码逻辑

1、读取配置文件（连接地址、用户名、密码）
2、建立数据库连接
3、执行数据sql
4、遍历sql执行结结果并返回

public   List connect_MySql(Class  classname,String  sql) throws ClassNotFoundException, SQLException, IOException 

        Statement  stt;
        Connection  conn; //数据库连接
        ResultSet rs; //数据库查询结果存储对象
        ResultSetMetaData rsmd;

        //创建读取配置文件对象
        Properties  prop=new Properties();

        //class.getClassLoader()创建一个加载器，相当于创建一个类对象
        //getResourceAsStream创建文件流
        InputStream  in=classname.getClassLoader().getResourceAsStream("forge.properties");

        //加载配置文件
        prop.load(in);

        //读取配置文件中的数据库驱动和连接属性值
        String  driverName=prop.getProperty("driverName");
        String  dbURL=prop.getProperty("dbURL");
        String  userName=prop.getProperty("userName");
        String  userPwd=prop.getProperty("userPwd");

        //加载数据库驱动，数据库不同驱动也不相同
        //maysql驱动是com.mysql.cj.jdbc.Driver
        Class.forName(driverName);

        //连接数据库且创建数据库对象
        conn= DriverManager.getConnection(dbURL,userName,userPwd);
        stt=conn.createStatement();

        //执行sql语句
        rs=stt.executeQuery(sql);

        //获取sql执行后的数据data
        rsmd=rs.getMetaData();

        //获取sql执行后数据的列数量
        int  rsmdCount=rsmd.getColumnCount();

        //遍历取sql执行结果的列名，存到数组中
        String[]  columnValue=new  String[rsmdCount];
        for(int i =0;i<rsmdCount;i++)
            columnValue[i]= rsmd.getColumnLabel(i+1);
        

        //将每一行的数据遍历，每行数据存到map中，所有map存到list中
        List <Object> sqlList =new ArrayList<Object>() ;

        while (rs.next())
          Map<String,Object> map=new HashMap<String, Object>();
          for(int  i=0 ;i<rsmdCount;i++)
              map.put(columnValue[i],rs.getObject(columnValue[i]));
          
          sqlList.add(map);
        
        System.out.println("---------sqlList----------:"+sqlList);

        if(stt!=null)  stt.close();
        if(conn!=null) conn.close();

        return sqlList;