连接mysql数据库

spring框架将JDBC进行了封装，使用 JdbcTemplate 方便实现对数据库操作
（spring5要求jdk不能低于1.8）

数据库

引入相关 jar 包

所需jar包

导入方法

新建包，创建一些类

dao层
UserDao

package com.dao;

import com.entity.User;

import java.util.List;

public interface UserDao {
    void add(User user);
    void updateUser(User user);
    void delete(String id);
    List<User> findAll();
    User findone();
}

UserDaoImpl

package com.dao;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;
import com.entity.User;

import java.util.List;

@Repository
public class UserDaoImpl implements UserDao {
    //注入 JdbcTemplate
    @Autowired
    private JdbcTemplate jdbcTemplate;

    //添加的方法
    @Override
    public void add(User user) {
        //1 创建 sql 语句
        String sql = "insert into user values(?,?,?)";
        //2 调用方法实现
        Object[] args = {user.getUserId(), user.getUserName(), user.getUserAge()};
        int update = jdbcTemplate.update(sql,args);
        System.out.println(update);

    }

//    修改
    @Override
    public void updateUser(User user) {
        String sql="update user set userName=?,userAge=? where userId=?";
        Object[] args = {user.getUserName(), user.getUserAge(),user.getUserId()};
        int update = jdbcTemplate.update(sql,args);
        System.out.println(update);
    }
//删除
    @Override
    public void delete(String name) {
        String sql = "delete from user where  =?";
        int update = jdbcTemplate.update(sql, name);
        System.out.println(update);
    }

    //查询
    @Override
    public User findone() {
        String sql = "select * from user where userId='1'";
        return   jdbcTemplate.queryForObject(sql , new BeanPropertyRowMapper<User>(User.class));
    }


}

Service层

package com.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.dao.UserDao;
import com.entity.User;

import java.util.List;

@Service
public class UserService {
    @Autowired
    private UserDao userDao;

    public void addUser(User user){
        userDao.add(user);
    }
    public void updateuser(User user){
        userDao.updateUser(user);
    }
   	
    public void deleteUser(String id){
        userDao.delete(id);
    }
    public User findoneInfo(){
        return userDao.findone();
    }
}

创建实体类
entity包下创建类
实体类属性必须和数据库中保持一致

package com.entity;

public class User {
    private String userId;
    private String userName;
    private String userAge;

    public void setUserId(String userId) {
        this.userId = userId;
    }

    public void setUserName(String userName) {
        this.userName = userName;
    }

    public void setUserAge(String userAge) {
        this.userAge = userAge;
    }

    public String getUserId() {
        return userId;
    }

    public String getUserName() {
        return userName;
    }

    public String getUserAge() {
        return userAge;
    }
    
}

新建xml文件，进行配置

xml文件在src下（这样做为了方便，也可以放在其他地方，调用的时候注意路径问题就行）

代码

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

<!--&lt;!&ndash; 组件扫描 &ndash;&gt;-->
    <context:component-scan base-package="com"/>

    <!--连接池-->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
          destroy-method="close">
        <property name="url" value="jdbc:mysql:///spring5?useSSL=false"/>
        <property name="username" value="root" />
        <property name="password" value="123456" />
        <property name="driverClassName" value="com.mysql.jdbc.Driver" />
    </bean>

    <!-- JdbcTemplate 对象 -->
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <!--注入 dataSource-->
        <property name="dataSource" ref="dataSource"/><!--set方式注入-->
    </bean>


</beans>

测试与结果

在test包下进行测试

package com.test;


import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.entity.User;
import com.service.UserService;
import org.testng.annotations.Test;

import java.util.List;

public class testUserService {
//    增
    @Test
    public void test1(){
        ApplicationContext context =
                new ClassPathXmlApplicationContext("bean1.xml");

        UserService userService = context.getBean("userService", UserService.class);

        User textuser= new User();
        textuser.setUserId("1");
        textuser.setUserName("赛文");
        textuser.setUserAge("16");

        userService.addUser(textuser);
    }
}

增加数据结果

删除数据

//    删
    @Test
    public void test2(){
        ApplicationContext context =
                new ClassPathXmlApplicationContext("bean1.xml");

        UserService userService = context.getBean("userService", UserService.class);

        String name="aotomen";

        userService.deleteUser(name);
    }

删除结果

修改数据

//    改
    @Test
    public void test3() {
        ApplicationContext context =
                new ClassPathXmlApplicationContext("bean1.xml");

        UserService userService = context.getBean("userService", UserService.class);

        User textuser2 = new User();
        textuser2.setUserId("1");
        textuser2.setUserName("泰罗");
        textuser2.setUserAge("16");

        userService.updateuser(textuser2);
    }

修改结果

查询数据

//    查
    @Test
    public void test4(){
        ApplicationContext context =
                new ClassPathXmlApplicationContext("bean1.xml");

        UserService userService = context.getBean("userService", UserService.class);

        User user =userService.findoneInfo();
        System.out.println(user.getUserId()+"n" +user.getUserName()+"n"+user.getUserAge());
    }

查询结果

最后

以上就是怡然树叶为你收集整理的spring连接mysql数据库实现增删改查连接mysql数据库的全部内容，希望文章能够帮你解决spring连接mysql数据库实现增删改查连接mysql数据库所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。