标签 Mysql 下的文章

2024-08-14

所有,vue.js

以下是一个使用宝塔面板部署Vue.js + Spring Boot + MySQL + Redis项目的基本步骤示例：

在服务器上安装宝塔面板。
通过宝塔面板安装Nginx、MySQL、Java、Redis。
创建数据库和用户，导入数据库备份。
配置Redis。
配置Java环境，部署Spring Boot项目。
配置Nginx，用于代理Vue.js前端请求。
配置SSL证书，启用HTTPS。
测试部署是否成功。

具体命令和配置可能根据实际环境和需求有所不同，但以上步骤为部署提供了保姆级指导。

Mybatis-Plus处理Mysql Json类型字段

2024-08-13

MyBatis-Plus 本身不直接支持 MySQL 的 JSON 类型字段，但你可以通过自定义类型处理器（TypeHandler）来实现。

以下是一个简单的例子，演示如何为 MySQL 的 JSON 类型字段创建一个自定义类型处理器：




import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.extension.parsers.IbatisSqlSessionFactoryBean;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.ibatis.type.BaseTypeHandler;
import org.apache.ibatis.type.JdbcType;
import org.apache.ibatis.annotations.Mapper;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;
import java.io.IOException;
import java.sql.*;
 
@Mapper
public interface YourEntityMapper extends BaseMapper<YourEntity> {
    // Your mapper methods here
}
 
@Component
public class JsonTypeHandler<T> extends BaseTypeHandler<T> {
    private static final ObjectMapper objectMapper = new ObjectMapper();
    private Class<T> type;
 
    public JsonTypeHandler(Class<T> type) {
        if (type == null) throw new IllegalArgumentException("Type argument cannot be null");
        this.type = type;
    }
 
    @Override
    public void setNonNullParameter(PreparedStatement ps, int i, T parameter, JdbcType jdbcType) throws SQLException {
        ps.setString(i, toJSON(parameter));
    }
 
    @Override
    public T getNullableResult(ResultSet rs, String columnName) throws SQLException {
        return toObject(rs.getString(columnName), type);
    }
 
    @Override
    public T getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
        return toObject(rs.getString(columnIndex), type);
    }
 
    @Override
    public T getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
        return toObject(cs.getString(columnIndex), type);
    }
 
    private String toJSON(T object) {
        try {
            return objectMapper.writeValueAsString(object);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
 
    private T toObject(String json, Class<T> clazz) {
        if (json == null || json.length() == 0) {

MySQL 8 中的窗口函数详解

2024-08-13

窗口函数（Window Function）是MySQL 8.0中新增的特性，可以用来计算聚合函数的值，但不会影响查询结果中的行数。窗口函数在SELECT语句的SELECT列表中指定，并且通常与OVER子句一起使用，定义了函数工作的窗口。

窗口函数可以分为以下几类：

聚合窗口函数：如ROW\_NUMBER(), RANK(), DENSE\_RANK(), SUM(), AVG(), COUNT(), MIN(), MAX()等。
排序窗口函数：如RANK(), DENSE\_RANK(), PERCENT\_RANK(), CUME\_DIST()等。
首尾窗口函数：如FIRST\_VALUE(), LAST\_VALUE()等。
聚合起始窗口函数：如LEAD(), LAG()等。
NTILE窗口函数。

以下是一个使用窗口函数的例子，假设我们有一个名为sales的表，包含year和revenue两个字段：




SELECT 
    year, 
    revenue, 
    SUM(revenue) OVER (ORDER BY year) AS running_total,
    AVG(revenue) OVER (ORDER BY year ROWS BETWEEN 1 PRECEDING AND CURRENT ROW) AS moving_average
FROM 
    sales;

在这个例子中，SUM()是一个聚合窗口函数，用于计算按year排序的累计收入。OVER子句定义了窗口的范围，这里是ORDER BY year，表示按年份排序。AVG()是另一个窗口函数，用于计算当前行、前一行的平均值，这里使用了ROWS BETWEEN 1 PRECEDING AND CURRENT ROW来指定窗口范围。

Linux--MYSQL 密码修改（四种方式）

2024-08-13

在Linux环境下修改MySQL的密码，可以通过以下四种方式进行：

使用mysqladmin工具：




mysqladmin -u root -p'oldpassword' password 'newpassword'

使用MySQL的SET PASSWORD命令：
登录到MySQL后，执行以下命令：




SET PASSWORD FOR 'username'@'localhost' = PASSWORD('newpassword');

或者，如果你想要修改当前登录用户的密码：




SET PASSWORD = PASSWORD('newpassword');

使用MySQL的ALTER USER命令：
登录到MySQL后，执行以下命令：




ALTER USER 'username'@'localhost' IDENTIFIED BY 'newpassword';

使用mysql客户端：




mysql -u root -p

登录后，使用以下命令修改密码：




UPDATE mysql.user SET authentication_string=PASSWORD('newpassword') WHERE User='username' AND Host='localhost';
FLUSH PRIVILEGES;

注意：

在使用以上命令时，请将username、localhost、oldpassword和newpassword替换为实际的用户名、主机名以及新旧密码。
从MySQL 5.7开始，mysqladmin的密码选项已被弃用，推荐使用ALTER USER或SET PASSWORD。
确保在执行这些操作后，对于使用了root账户的操作，记得立即更新所有其他的管理员账户密码，以增强系统安全性。

MySQL·复合查询

2024-08-13

复合查询是指在MySQL中使用多个查询语句（如UNION, UNION ALL, EXISTS, IN, ANY, ALL等）来构建单个查询结果的操作。以下是一些常见的复合查询示例：

使用UNION来合并两个或多个SELECT语句的结果集，自动去除重复行：




SELECT column_name(s) FROM table1
UNION
SELECT column_name(s) FROM table2;

使用UNION ALL来合并两个或多个SELECT语句的结果集，包含所有行（包括重复行）：




SELECT column_name(s) FROM table1
UNION ALL
SELECT column_name(s) FROM table2;

使用EXISTS子查询检查一个查询是否返回任何行：




SELECT column_name(s) FROM table1
WHERE EXISTS (SELECT 1 FROM table2 WHERE condition);

使用IN子查询来检查一个值是否存在于另一个查询的结果集中：




SELECT column_name(s) FROM table1
WHERE column_name IN (SELECT column_name FROM table2);

使用ANY或SOME来检查一个值是否符合子查询中的任何（至少一个）值：




SELECT column_name(s) FROM table1
WHERE column_name operator ANY (SELECT column_name FROM table2);

使用ALL来检查一个值是否符合子查询中的所有值：




SELECT column_name(s) FROM table1
WHERE column_name operator ALL (SELECT column_name FROM table2);

这些复合查询可以用于多种不同的场景，例如数据合并、数据筛选、关联表查询等。

08.MySQL大小写

2024-08-13

MySQL的表名和列名是对大小写敏感的，如果在创建表或列时使用了双引号，则MySQL会将标识符存储为区分大小写的值。如果没有使用双引号，MySQL默认会将标识符转换为小写。

例如：




CREATE TABLE myTable (
    id INT
);
 
SELECT * FROM mytable;  -- 正确，MySQL会自动转换为小写
SELECT * FROM "myTable";  -- 错误，除非表名用双引号创建
SELECT * FROM "MyTable";  -- 正确，如果表名用双引号创建，则保留大小写

为了保证在查询时不受大小写影响，最好在创建表和列时使用统一的命名规则，并在引用时保持一致的大小写。如果确实需要使用双引号来保留大小写，请确保在引用时也使用相同的大小写。

2024-08-13

要在Docker中部署Kettle（又称Pentaho Data Integration, PDI）并与Sqlserver数据同步到MySQL，你需要执行以下步骤：

创建Dockerfile来构建包含Kettle的Docker镜像。
设置Kettle作业（job）来执行数据同步。
使用Docker命令构建镜像并运行容器。
设置定时任务（Cron Job）来定期执行该Docker容器。

以下是一个简化的Dockerfile示例，它安装了Kettle和数据库驱动：




FROM centos:7
 
# 安装Java
RUN yum install -y java-1.8.0-openjdk
 
# 安装Kettle
RUN wget https://sourceforge.net/projects/pentaho/files/Data Integration/7.1/pdi-ce-7.1.0.0-12.zip/download -O kettle.zip
RUN unzip kettle.zip -d /usr/lib/kettle
 
# 安装MySQL JDBC驱动
RUN wget https://dev.mysql.com/get/Downloads/Connector-J/mysql-connector-java-8.0.23.tar.gz
RUN tar zxvf mysql-connector-java-8.0.23.tar.gz
RUN cp mysql-connector-java-8.0.23/mysql-connector-java-8.0.23.jar /usr/lib/kettle/lib/
 
# 安装Sqlserver JDBC驱动
RUN yum install -y mssql-jdbc
 
# 创建Kettle作业脚本
COPY sync_sqlserver_to_mysql.kjb /usr/lib/kettle/jobs/
 
# 设置Cron定时任务
RUN crontab -e <<EOF
0 * * * * /usr/lib/kettle/kitchen.sh /usr/lib/kettle/jobs/sync_sqlserver_to_mysql.kjb
EOF
 
# 设置工作目录
WORKDIR /usr/lib/kettle
 
# 设置环境变量
ENV JAVA_HOME /usr/lib/jvm/jre-openjdk
 
# 对外暴露端口（如果需要通过Web方式访问Kettle）
EXPOSE 8080
 
# 启动Kettle服务器
CMD ["/usr/lib/kettle/carte.sh", "-port=8080", "-master=localhost"]

在这个Dockerfile中，我们安装了Java环境、Kettle，并且设置了MySQL和Sqlserver的JDBC驱动。我们复制了同步作业脚本到Kettle的作业目录，并通过crontab设置了每小时执行同步作业的定时任务。

同步作业脚本sync_sqlserver_to_mysql.kjb需要你自己创建，并在Docker构建过程中复制到指定目录。

构建和运行Docker镜像的命令如下：




docker build -t kettle-sqlserver-mysql .
docker run -d kettle-sqlserver-mysql

这样，你就设置了一个定时执行的数据同步任务，该任务在Docker容器内部运行，并且使用了Kettle作业来处理数据。

【Linux 无网络状态下离线安装 MySQL】

2024-08-13

离线安装MySQL的步骤通常如下：

从MySQL官网下载对应Linux版本的.tar.gz安装包。
将安装包传输到目标Linux服务器上。
解压安装包并进行安装。

以下是一个基于Linux的简化示例流程：




# 1. 下载MySQL (以MySQL 8.0为例)
wget https://dev.mysql.com/get/Downloads/MySQL-8.0/mysql-8.0.23-linux-glibc2.17-x86_64.tar.gz
 
# 2. 解压安装包
tar -zxvf mysql-8.0.23-linux-glibc2.17-x86_64.tar.gz
 
# 3. 创建MySQL用户和组
groupadd mysql
useradd -r -g mysql -s /bin/false mysql
 
# 4. 移动解压后的文件夹到目标安装目录
mv mysql-8.0.23-linux-glibc2.17-x86_64 /usr/local/mysql
 
# 5. 更改目录权限
chown -R mysql:mysql /usr/local/mysql
 
# 6. 初始化数据库
cd /usr/local/mysql
bin/mysqld --initialize --user=mysql
 
# 7. 安装服务脚本
cp support-files/mysql.server /etc/init.d/mysql
chmod +x /etc/init.d/mysql
 
# 8. 配置my.cnf (如果需要的话)
# 通常在 /etc/my.cnf
 
# 9. 启动MySQL服务
service mysql start
 
# 10. 设置环境变量
echo 'export PATH=/usr/local/mysql/bin:$PATH' >> ~/.bashrc
source ~/.bashrc
 
# 11. 安全配置MySQL（设置root密码等）
mysql_secure_installation

请确保所有步骤均在适当的目录下执行，并根据实际的MySQL版本和Linux发行版进行适配。如果你的Linux系统是基于Red Hat的（如RHEL, CentOS），你可能需要使用 yum 或 rpm 来安装依赖，或者使用 systemd 来管理服务。

大数据Canal：使用Canal同步MySQL数据

2024-08-13




import com.alibaba.otter.canal.client.CanalConnector;
import com.alibaba.otter.canal.client.CanalConnectors;
import com.alibaba.otter.canal.protocol.Message;
import com.alibaba.otter.canal.protocol.CanalEntry;
 
import java.net.InetSocketAddress;
import java.util.List;
 
public class SimpleCanalClientExample {
 
    public static void main(String args[]) {
        // 创建连接
        CanalConnector connector = CanalConnectors.newSingleConnector(
                new InetSocketAddress(AddressUtils.getHostIp(),
                11111), "example", "", "");
 
        int batchSize = 1000;
        try {
            connector.connect();
            connector.subscribe(".*\\..*");
            connector.rollback();
            while (true) {
                Message message = connector.getWithoutAck(batchSize); // 获取指定数量的数据
                long batchId = message.getId();
                if (batchId == -1 || message.getEntries().isEmpty()) {
                    Thread.sleep(1000);
                } else {
                    dataHandle(message.getEntries());
                    connector.ack(batchId); // 确认消息消费成功
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            connector.disconnect();
        }
    }
 
    private static void dataHandle(List<CanalEntry.Entry> entrys) {
        for (CanalEntry.Entry entry : entrys) {
            if (entry.getEntryType() == CanalEntry.EntryType.TRANSACTIONBEGIN || entry.getEntryType() == CanalEntry.EntryType.TRANSACTIONEND) {
                continue;
            }
            CanalEntry.RowChange rowChage = null;
            try {
                rowChage = CanalEntry.RowChange.parseFrom(entry.getStoreValue());
            } catch (Exception e) {
                throw new RuntimeException("ERROR ## parser of eromanga-event has an error , data:" + entry.toString(), e);
            }
 
            switch (rowChage.getEventType()) {
                case INSERT:
                    // 处理插入数据
                    break;
                case UPDATE:
                    // 处理更新数据

Mysql图书借阅管理系统设计

2024-08-13




-- 创建图书借阅管理系统所需的数据库和表
CREATE DATABASE IF NOT EXISTS lib_system;
USE lib_system;
 
-- 创建用户表
CREATE TABLE IF NOT EXISTS users (
    user_id INT AUTO_INCREMENT PRIMARY KEY,
    username VARCHAR(50) NOT NULL,
    password VARCHAR(50) NOT NULL,
    email VARCHAR(100),
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);
 
-- 创建图书表
CREATE TABLE IF NOT EXISTS books (
    book_id INT AUTO_INCREMENT PRIMARY KEY,
    title VARCHAR(100) NOT NULL,
    author VARCHAR(100) NOT NULL,
    isbn VARCHAR(50) NOT NULL,
    published_year YEAR,
    category VARCHAR(100),
    total_copies INT NOT NULL,
    available_copies INT NOT NULL,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);
 
-- 创建借书记录表
CREATE TABLE IF NOT EXISTS book_loans (
    loan_id INT AUTO_INCREMENT PRIMARY KEY,
    user_id INT NOT NULL,
    book_id INT NOT NULL,
    loan_date DATE NOT NULL,
    return_date DATE,
    FOREIGN KEY (user_id) REFERENCES users(user_id),
    FOREIGN KEY (book_id) REFERENCES books(book_id),
    UNIQUE (user_id, book_id, loan_date)
);

这个例子展示了如何使用SQL语句来创建一个简单的图书借阅管理系统所需的数据库和表。这里包括了用户表、图书表以及借书记录表，并通过外键约束保证数据的完整性。