This commit is contained in:
2025-08-18 13:13:57 +08:00
parent b382150514
commit 3e69b5db37
7 changed files with 1 additions and 315 deletions

View File

@ -1,24 +0,0 @@
package com.example.practice.controller;
import com.example.practice.entity.User;
import com.example.practice.mapper.UserMapper;
import com.example.practice.mapper.UserMapperImpl;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
@RestController
@RequestMapping("/user")
public class UserController {
UserMapper userMapper = new UserMapperImpl();
@RequestMapping("/query")
public List<User> query() {
return userMapper.selectList();
}
}

View File

@ -1,19 +0,0 @@
package com.example.practice.mapper;
import com.example.practice.entity.User;
import java.util.List;
public interface UserMapper {
int insert (User user);
int delete(Long id);
int update(User user);
User selectOne(Long id);
List<User> selectList();
}

View File

@ -1,74 +0,0 @@
package com.example.practice.mapper;
import com.example.practice.entity.User;
import com.example.practice.utils.SqlSessionFactoryUtil;
import org.apache.ibatis.session.SqlSession;
import java.util.List;
public class UserMapperImpl implements UserMapper {
@Override
public int insert(User user) {
SqlSession sqlSession = SqlSessionFactoryUtil.getSqlSession();
try {
UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
int result = userMapper.insert(user);
if (result == 0) throw new RuntimeException("添加失败");
sqlSession.commit();
} catch (Exception e) {
sqlSession.rollback();
} finally {
sqlSession.close();
}
return 1;
}
@Override
public int delete(Long id) {
SqlSession sqlSession = SqlSessionFactoryUtil.getSqlSession();
try {
UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
int result = userMapper.delete(id);
if (result == 0) throw new RuntimeException("删除失败");
sqlSession.commit();
} catch (Exception e) {
sqlSession.rollback();
} finally {
sqlSession.close();
}
return 1;
}
@Override
public int update(User user) {
SqlSession sqlSession = SqlSessionFactoryUtil.getSqlSession();
try {
UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
int result = userMapper.update(user);
if (result == 0) throw new RuntimeException("更新失败");
sqlSession.commit();
} catch (Exception e) {
sqlSession.rollback();
} finally {
sqlSession.close();
}
return 1;
}
@Override
public User selectOne(Long id) {
SqlSession sqlSession = SqlSessionFactoryUtil.getSqlSession();
UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
User user = userMapper.selectOne(id);
return user;
}
@Override
public List<User> selectList() {
SqlSession sqlSession = SqlSessionFactoryUtil.getSqlSession();
UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
List<User> users = userMapper.selectList();
return users;
}
}

View File

@ -1,103 +0,0 @@
package com.example.practice.sqlsession;
import com.example.practice.entity.User;
import com.example.practice.utils.SqlSessionFactoryUtil;
import org.apache.ibatis.session.SqlSession;
import java.io.IOException;
import java.util.List;
public class SqlSessionPlusTest {
public static void main(String[] args) throws IOException {
SqlSession sqlSession = SqlSessionFactoryUtil.getSqlSession();
// 插入
User insertUser = new User();
insertUser.setId(null);
insertUser.setNickName("管理员2");
insertUser.setPhoneNumber("12345678901");
insertUser.setUserAccount("admin2");
insertUser.setUserPassword("12345678");
insertUser.setUserRole("admin");
insert(sqlSession, insertUser);
// 根据id删除
delete(sqlSession, 12L);
// 修改
User updateUser = new User();
updateUser.setId(11L);
updateUser.setNickName("管理员dsfaf2");
updateUser.setPhoneNumber("fdsdsgsfdsf");
updateUser.setUserAccount("fds");
updateUser.setUserPassword("12345678");
updateUser.setUserRole("admin");
update(sqlSession, updateUser);
// 查询
selectList(sqlSession);
// 根据id查询
selectOne(sqlSession, 4L);
}
private static void insert(SqlSession sqlSession, User user) {
try {
int result = sqlSession.insert("fdeawgryer.insert", user);
if (result == 0) throw new RuntimeException("添加失败");
sqlSession.commit();
} catch (Exception e) {
sqlSession.rollback();
} finally {
sqlSession.close();
}
}
private static void delete(SqlSession sqlSession, Long id) {
try {
int result = sqlSession.delete("fdeawgryer.delete", id);
if (result == 0) throw new RuntimeException("删除失败");
sqlSession.commit();
} catch (Exception e) {
sqlSession.rollback();
} finally {
sqlSession.close();
}
}
private static void update(SqlSession sqlSession, User user) {
try {
int result = sqlSession.update("fdeawgryer.update", user);
if (result == 0) throw new RuntimeException("更新失败");
sqlSession.commit();
} catch (Exception e) {
sqlSession.rollback();
} finally {
sqlSession.close();
}
}
private static void selectList(SqlSession sqlSession) {
List<User> userList = sqlSession.selectList("fdeawgryer.dfsakdf");
for (User user : userList) {
System.out.println(user);
}
}
private static void selectOne(SqlSession sqlSession, Long id) {
User user = sqlSession.selectOne("fdeawgryer.selectOne", id);
System.out.println(user);
}
}

View File

@ -1,60 +0,0 @@
package com.example.practice.sqlsession;
import com.example.practice.entity.User;
import com.example.practice.mapper.UserMapper;
import com.example.practice.mapper.UserMapperImpl;
import com.example.practice.utils.SqlSessionFactoryUtil;
import org.apache.ibatis.session.SqlSession;
import java.io.IOException;
import java.util.List;
public class SqlSessionSPlusTest {
private static final UserMapper userMapper = new UserMapperImpl();
public static void main(String[] args) throws IOException {
SqlSession sqlSession = SqlSessionFactoryUtil.getSqlSession();
List<User> userList = sqlSession.selectList("fdeawgryer.dfsakdf");
userList.forEach(System.out::println);
// // 插入
// User insertUser = new User();
// insertUser.setId(null);
// insertUser.setNickName("管理员2");
// insertUser.setPhoneNumber("12345678901");
// insertUser.setUserAccount("admin2");
// insertUser.setUserPassword("12345678");
// insertUser.setUserRole("admin");
// userMapper.insert(insertUser);
//
//
// // 根据id删除
// userMapper.delete(12L);
//
//
// // 修改
// User updateUser = new User();
// updateUser.setId(11L);
// updateUser.setNickName("管理员dsfaf2");
// updateUser.setPhoneNumber("fdsdsgsfdsf");
// updateUser.setUserAccount("fds");
// updateUser.setUserPassword("12345678");
// updateUser.setUserRole("admin");
// userMapper.update(updateUser);
// // 查询
// List<User> users = userMapper.selectList();
// users.forEach(System.out::println);
// // 根据id查询
// userMapper.selectOne(4L);
}
}

View File

@ -1,34 +0,0 @@
package com.example.practice.utils;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import java.io.IOException;
import java.io.InputStream;
public class SqlSessionFactoryUtil {
private static SqlSessionFactory sqlSessionFactory;
static {
String path = "mybatis-config.xml";
// 文件字节流
InputStream is = null;
try {
is = Resources.getResourceAsStream(path);
} catch (IOException e) {
e.printStackTrace();
}
SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();
sqlSessionFactory = sqlSessionFactoryBuilder.build(is);
}
public static SqlSession getSqlSession() {
return sqlSessionFactory.openSession();
}
}

View File

@ -2,7 +2,7 @@
<!DOCTYPE mapper <!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd"> "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.example.practice.mapper.UserMapper"> <mapper namespace="sdfdsafdfd">
<select id="selectList" resultType="com.example.practice.entity.User"> <select id="selectList" resultType="com.example.practice.entity.User">
select * from user select * from user
</select> </select>