点一下关注吧!!!非常感谢!!持续更新!!!
大数据篇正在更新!https://blog.csdn.net/w776341482/category_12713819.html
目前已经更新到了:
MyBatis(正在更新)框架实现
在当前的项目中,在 resources 下新建:
sqlMapConfig.xmlmapper.xmlsqlMapConfig.xml
<?xml version="1.0" encoding="UTF-8"?><configuration> <property name="driverClass" value="com.mysql.cj.jdbc.Driver"></property> <property name="jdbcUrl" value="jdbc:mysql://172.16.1.130:3306/wzk-mybatis?characterEncoding=utf-8"></property> <property name="user" value="hive"></property> <property name="password" value="hive@wzk.icu"></property> <mapper resource="mapper.xml"></mapper></configuration>
对应的截图如下所示:
这段代码是一个 MyBatis 的配置文件,通常命名为 mybatis-config.xml 或类似的名字。它主要完成以下任务:
配置数据库连接属性,例如驱动类、JDBC URL、用户名和密码。引入 MyBatis 的映射文件,用于定义 SQL 语句和映射关系。mapper.xml
实现一个单查询和列表的查询
<mapper namespace="icu.wzk.dao.UserInfoMapper"> <select id="selectOne" parameterType="icu.wzk.model.UserInfo" resultType="icu.wzk.model.UserInfo"> SELECT * FROM user_info WHERE username=#{username} </select> <select id="selectList" parameterType="icu.wzk.model.UserInfo" resultType="icu.wzk.model.UserInfo"> SELECT * FROM user_info </select></mapper>
对应的截图如下所示:
命名空间 (namespace):
单条记录查询 (selectOne):
select id=“selectOne” parameterType=“icu.wzk.model.UserInfo” resultType=“icu.wzk.model.UserInfo”:这是一个 select 标签,用于查询单条记录。id=“selectOne” 定义了方法名称,与 UserInfoMapper 接口中的方法名对应。parameterType=“icu.wzk.model.UserInfo” 指定了方法的参数类型,这里是 UserInfo 对象。resultType=“icu.wzk.model.UserInfo” 指定了返回结果的类型,同样是 UserInfo 对象。实体相关
model
新建一个实体类,UserInfo
package icu.wzk.model;import lombok.Data;@Datapublic class UserInfo { private Long id; private String username; private String password; private Integer age;}
资源相关
Configuration
package icu.wzk.bean;import lombok.Data;import javax.sql.DataSource;import java.util.HashMap;import java.util.Map;@Datapublic class Configuration { private DataSource dataSource; private Map<String, MappedStatement> mappedStatementMap = new HashMap<>();}
MappedStatment
package icu.wzk.bean;import lombok.Data;@Datapublic class MappedStatement { private String id; private String sql; private String parameterType; private String resultType;}
Resources
package icu.wzk.bean;import java.io.InputStream;public class Resources { public static InputStream getResourceAsStream(String path) { return Resources.class.getClassLoader().getResourceAsStream(path); }}
解析相关
XMLConfigerBuilder
package icu.wzk.bean;import com.mchange.v2.c3p0.ComboPooledDataSource;import org.dom4j.Document;import org.dom4j.DocumentException;import org.dom4j.Element;import org.dom4j.io.SAXReader;import java.beans.PropertyVetoException;import java.io.InputStream;import java.util.List;import java.util.Properties;public class XMLConfigerBuilder { private Configuration configuration; public XMLConfigerBuilder(Configuration configuration) { this.configuration = configuration; } public Configuration parseConfiguration(InputStream inputStream) throws DocumentException, PropertyVetoException, ClassNotFoundException { Document document = new SAXReader().read(inputStream); Element rootElement = document.getRootElement(); List<Element> propertyElements = rootElement.selectNodes("//property"); Properties properties = new Properties(); for (Element element : propertyElements) { String name = element.attributeValue("name"); String value = element.attributeValue("value"); properties.setProperty(name, value); } ComboPooledDataSource comboSource = new ComboPooledDataSource(); comboSource.setDriverClass(properties.getProperty("driverClass")); comboSource.setJdbcUrl(properties.getProperty("jdbcUrl")); comboSource.setUser(properties.getProperty("user")); comboSource.setPassword(properties.getProperty("password")); configuration.setDataSource(comboSource); List<Element> mappedElements = rootElement.selectNodes("//mapper"); XMLMapperBuilder xmlMapperBuilder = new XMLMapperBuilder(configuration); for (Element element : mappedElements) { String mapperPath = element.attributeValue("resource"); InputStream resourceAsStream = Resources.getResourceAsStream(mapperPath); xmlMapperBuilder.parse(resourceAsStream); } return configuration; } }
这段代码是一个用于解析 XML 配置文件的 Java 类,主要作用是读取 XML 配置文件内容,初始化应用程序所需的配置信息(例如数据库连接池配置、Mapper 文件解析等)。
类的定义
类名 XMLConfigerBuilder:表示这是一个 XML 配置解析器。
成员变量 configuration:保存应用的配置信息,类型为 Configuration。
构造方法
XMLConfigerBuilder(Configuration configuration):通过构造方法将 Configuration 对象传入并保存在成员变量中。
parseConfiguration 方法
该方法负责解析 XML 文件并初始化 Configuration 对象,主要包括以下几个步骤:
解析 XML 文档:
读取数据库配置:
查找 XML 中的 节点,解析出 name 和 value 属性,将其存入 Properties 对象。创建 ComboPooledDataSource 对象,用于配置数据库连接池,设置驱动类、URL、用户名和密码等信息。将初始化好的数据源对象设置到 configuration 中。解析 Mapper 文件
查找 XML 中的 节点,提取每个节点的 resource 属性值(Mapper 文件路径)。逐个读取 Mapper 文件,通过 XMLMapperBuilder 的 parse 方法解析每个文件,将其结果更新到 configuration 中。返回最终的 Configuration 对象
方法执行完成后,返回已经完整解析并初始化的 Configuration 对象。XMLMapperBuilder
package icu.wzk.bean;import org.dom4j.Document;import org.dom4j.DocumentException;import org.dom4j.Element;import org.dom4j.io.SAXReader;import java.io.InputStream;import java.util.List;public class XMLMapperBuilder { private Configuration configuration; public XMLMapperBuilder(Configuration configuration) { this.configuration = configuration; } public void parse(InputStream inputStream) throws DocumentException, ClassNotFoundException { Document document = new SAXReader().read(inputStream); Element rootElement = document.getRootElement(); String namespace = rootElement.attributeValue("namespace"); List<Element> selectList = rootElement.selectNodes("select"); for (Element element : selectList) { String id = element.attributeValue("id"); String parameterType = element.attributeValue("parameterType"); String resultType = element.attributeValue("resultType"); String key = namespace + "." + id; String textTrim = element.getTextTrim(); MappedStatement mappedStatement = new MappedStatement(); mappedStatement.setId(id); mappedStatement.setParameterType(parameterType); mappedStatement.setResultType(resultType); mappedStatement.setSql(textTrim); configuration.getMappedStatementMap().put(key, mappedStatement); } }}