Springboot+mysql簡單的spring操作

1.目錄結構

jdbcUtil程式碼

package com.springboot.first.jdbcUtil; import java.sql.*;

public class JdbcUtil { private static String DRIVER = “com.mysql.jdbc.Driver”; private static String USERNAME = “root”; private static String PASSWORD = “1234”; private static String URL = “jdbc:mysql://localhost:3306/USER”; private static Connection connection ;

/**
 *
 * Describe:獲得資料庫的連線
 * @Author: wwh
 * @Date: 2018/10/29 13:05
 * @Param: []
 * @Return: java.sql.Connection
 */
public static Connection getConnection(){


    try {
        Class.forName(DRIVER);
        connection =  DriverManager.getConnection(URL,USERNAME,PASSWORD);

    } catch (Exception e) {
        e.printStackTrace();
    }

    return  connection;
}

/**
 *
 * Describe:關閉資料庫操作
 * @Author: wwh
 * @Date: 2018/10/29 13:06
 * @Param: [connection, preparedStatement, resultSet]
 * @Return: void
 */
public static void close(Connection connection, PreparedStatement preparedStatement,
                         ResultSet resultSet){
    if(resultSet != null){
        try {
            resultSet.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    if(preparedStatement != null ){
        try {
            preparedStatement.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    if(connection != null){
        try {
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}
 

}

UserDao程式碼

package com.springboot.first.userDao;

import com.springboot.first.entity.User;

public interface UserDao {

//增加操作，成功返回1，失敗返回0 int addUser(User user);

}

UserDaoImpl

package com.springboot.first.userDao.userDaoImpl;

import com.springboot.first.entity.User; import com.springboot.first.jdbcUtil.JdbcUtil; import com.springboot.first.userDao.UserDao; import org.springframework.stereotype.Component;

import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;

@Component public class UserDaoImpl implements UserDao {

private PreparedStatement preparedStatement;
private Connection connection;
private ResultSet resultSet;

@Override
public int addUser(User user) {

    int result = 0;

    String sql = "INSERT INTO USER  VALUES(?,?,?,?,NOW())";
    try {
        connection = JdbcUtil.getConnection();
        preparedStatement = connection.prepareStatement(sql);
        preparedStatement.setString(1,user.getId());
        preparedStatement.setString(2,user.getUserName());
        preparedStatement.setString(3,user.getPassWord());
        preparedStatement.setInt(4,user.getAge());
        result =  preparedStatement.executeUpdate();
    } catch (SQLException e) {
        e.printStackTrace();
    }finally {
        if(preparedStatement != null){
            try {
                preparedStatement.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (connection != null){
            try {
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
    return result;
}

}

UserService

package com.springboot.first.userService;

import com.springboot.first.entity.User;

public interface UserService {

int addUser(User user);

}

UserServiceImpl

package com.springboot.first.userService;

import com.springboot.first.entity.User; import com.springboot.first.userDao.UserDao; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service;

@Service public class UserServiceImpl implements UserService {

@Autowired
private UserDao userDao;

@Override
public int addUser(User user) {
    return userDao.addUser(user);
}

}

Controller

package com.springboot.first.controller;

import com.springboot.first.entity.User; import com.springboot.first.userService.UserService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController;

@RestController @RequestMapping("/springboot") public class UserController {

@Autowired
private UserService userService;


@RequestMapping("/addUser")
public int addUser(){
    User user = new User();
    user.setAge(12);
    user.setId("1");
    user.setPassWord("123");
    user.setUserName("root");
    return userService.addUser(user);
}

}

頁面執行後結果

資料庫結果