Mybatis連接數據庫實例 + 完整代碼

Mybatis連接數據庫實例

1、 數據庫表

1.1、創建表

CREATE TABLE `users`(
`uid` INT NOT NULL AUTO_INCREMENT COMMENT '用戶id',
`uname` VARCHAR(20) NOT NULL COMMENT '用戶名',
`upass` VARCHAR(20) NOT NULL COMMENT '用戶密碼',
PRIMARY KEY (`uid`)
)ENGINE = INNODB DEFAULT CHARSET = utf8;

1.2、插入數據

INSERT INTO `users` (`uname`,`upass`) VALUES
('zhangwuji','123456'),
('zhaomin','123456'),
('zhouzhiruo','123456'),
('xiaozhao','123456');

1.3、查看表

​

2、 java部分

2.1根據數據庫表中的字段創建pojo對象

package com.cugb.pojo;

import lombok.ToString;

/**
 * @author huangjian
 * @data 2020/7/6 11:11
 */
public class Users {
    //用戶id
    private  int uid;

    //用戶名
    private String uname;

    //密碼
    private String upass;

    public Users() {
    }

    public Users(int uid, String uname, String upass) {
        this.uid = uid;
        this.uname = uname;
        this.upass = upass;
    }

    public int getUid() {
        return uid;
    }

    public void setUid(int uid) {
        this.uid = uid;
    }

    public String getUname() {
        return uname;
    }

    public void setUname(String uname) {
        this.uname = uname;
    }

    public String getUpass() {
        return upass;
    }

    public void setUpass(String upass) {
        this.upass = upass;
    }

    @Override
    public String toString() {
        return "uid:" +  uid +  "\t" +  "uname:" +  uname+  "\t" +"upass:" +  upass;
    }
}

2.2、dao層創建接口，並添加等方法

import com.cugb.pojo.Users;


import java.util.ArrayList;

public interface UsersDao {

	//查詢用戶
	public ArrayList<Users> queryUsers();

	//添加用戶
	public boolean addUser(Users user);

	//修改用戶
	public boolean changeUser(Map<String,String> map);
	

}

2.4、創建接口對應的Mapper(相當於dao的實現類)

UserDaoMapper.xml

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">

<!--命名空間namespace-->
<mapper namespace="com.cugb.dao.UsersDao">
    <!--sql語句-->
    <select id="queryUsers" resultType="Users">
        select * from users
    </select>

    <select id="addUser" parameterType="Users" >
        insert into users (uname, upass) VALUES (#{uname},#{upass});
    </select>

    <update id="changeUser" parameterType="Map">
        update users set upass = #{upass} where uid = #{uid};
    </update>
    
</mapper>

2.5、創建mybatis-config.xml,配置數據庫基本信息，並將mapper注冊到mybatis-config.xml

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-config.dtd">

<configuration>

    <!--引入外部配置文件-->
    <properties resource="db.properties"/>

    <settings>
        <setting name="logImpl" value="LOG4J"/>
    </settings>
    <!--可以給實體類起別名-->
        <typeAliases>
           <typeAlias type="com.cugb.pojo.Users" alias="users"/>
        </typeAliases>

    <environments default="development">
        <environment id="development">

            <!--  事物管理，JDBC的事物管理-->
            <transactionManager type="JDBC"/>

            <!--數據源，連接池型的數據源-->
            <dataSource type="POOLED">
                <property name="driver" value="${driver}"/>
                <property name="url" value="${url}"/>
                <property name="username" value="${username}"/>
                <property name="password" value="${password}"/>
            </dataSource>
        </environment>
    </environments>

    <!--綁定接口-->
    <mappers>
        <mapper resource="com/cugb/dao/UserDaoMapper.xml"/>
    </mappers>
        </configuration>

其中db.properties內容如下

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/mybatis?characterEncoding=UTF-8
username=root
password=123456

3、測試

3.1測試代碼

package com.cugb.test;

import com.cugb.dao.UsersDao;
import com.cugb.pojo.Users;
import lombok.SneakyThrows;
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 org.junit.Test;

import javax.management.Query;
import java.io.InputStream;
import java.util.ArrayList;

/**
 * @author huangjian
 * @data 2020/7/6 14:42
 */
public class UserDaoTest2 {

    @SneakyThrows
    @Test
    public void Query() {
        //加載配置文件
        InputStream in = Resources.getResourceAsStream("mybatis-config.xml");
		
        //獲取SqlSessionFactory 
        SqlSessionFactory sqlSessionFactory = new  SqlSessionFactoryBuilder().build(in);
		
        //獲取SqlSession
        SqlSession sqlSession = sqlSessionFactory.openSession();
		
        UsersDao usersDao = sqlSession.getMapper(UsersDao.class);

        ArrayList<Users> list = usersDao.queryUsers();

        for (Users users : list) {
            System.out.println(users);
        }

        sqlSession.close();

    }
}

3.2、結果

[org.apache.ibatis.transaction.jdbc.JdbcTransaction]-Opening JDBC Connection
[org.apache.ibatis.datasource.pooled.PooledDataSource]-Created connection 1848415041.
[org.apache.ibatis.transaction.jdbc.JdbcTransaction]-Setting autocommit to false on JDBC Connection [com.mysql.jdbc.JDBC4Connection@6e2c9341]
[com.cugb.dao.UsersDao.queryUsers]-==>  Preparing: select * from users 
[com.cugb.dao.UsersDao.queryUsers]-==> Parameters: 
[com.cugb.dao.UsersDao.queryUsers]-<==      Total: 4
uid:1	uname:zhangwuji	upass:123456
uid:2	uname:zhaomin	upass:123456
uid:3	uname:zhouzhiruo	upass:123456
uid:4	uname:xiaozhao	upass:123456
[org.apache.ibatis.transaction.jdbc.JdbcTransaction]-Resetting autocommit to true on JDBC Connection [com.mysql.jdbc.JDBC4Connection@6e2c9341]
[org.apache.ibatis.transaction.jdbc.JdbcTransaction]-Closing JDBC Connection [com.mysql.jdbc.JDBC4Connection@6e2c9341]
[org.apache.ibatis.datasource.pooled.PooledDataSource]-Returned connection 1848415041 to pool.