开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

mysql的split

基础概念

MySQL本身并没有内置的SPLIT函数，但可以通过其他函数或方法实现字符串分割的功能。常见的方法是使用SUBSTRING_INDEX、FIND_IN_SET或者自定义函数。

相关优势

灵活性：可以根据不同的分隔符灵活地分割字符串。
高效性：对于简单的分割任务，使用内置函数可以保持较高的执行效率。
可扩展性：可以通过自定义函数实现更复杂的分割逻辑。

类型与应用场景

使用`SUBSTRING_INDEX`

适用于按单个分隔符分割字符串。

SELECT 
    SUBSTRING_INDEX('apple,banana,orange', ',', 1) AS part1,
    SUBSTRING_INDEX(SUBSTRING_INDEX('apple,banana,orange', ',', 2), ',', -1) AS part2,
    SUBSTRING_INDEX('apple,banana,orange', ',', -1) AS part3;

应用场景：处理CSV文件、分割用户输入的多个值等。

使用`FIND_IN_SET`

适用于在逗号分隔的字符串列表中查找特定值。

SELECT * FROM table WHERE FIND_IN_SET('banana', 'apple,banana,orange');

应用场景：处理标签系统、权限管理等。

自定义函数

适用于更复杂的分割需求。

DELIMITER $$
CREATE FUNCTION SPLIT_STR(x VARCHAR(255), delim VARCHAR(12), pos INT)
RETURNS VARCHAR(255)
DETERMINISTIC
BEGIN
    RETURN REPLACE(SUBSTRING(SUBSTRING_INDEX(x, delim, pos),
           LENGTH(SUBSTRING_INDEX(x, delim, pos - 1)) + 1),
           delim, '');
END$$
DELIMITER ;

应用场景：处理复杂的数据格式、多级分类等。

遇到的问题及解决方法

问题：分割效率低下

原因：对于大量数据的分割，使用简单的字符串函数可能会导致性能问题。

解决方法：

优化查询：尽量减少不必要的分割操作，例如在查询时只进行必要的分割。
使用自定义函数：对于复杂的分割逻辑，可以编写高效的SQL函数。
预处理数据：在数据插入数据库时，预先分割好字符串并存储在多个字段中。

问题：分隔符冲突

原因：如果数据中包含与分隔符相同的字符，会导致分割错误。

解决方法：

转义分隔符：在分隔符前添加转义字符。
使用更复杂的分隔符：选择一个不太可能在数据中出现的字符作为分隔符。
自定义函数：编写函数处理转义字符和复杂分隔符的情况。

示例代码

-- 使用SUBSTRING_INDEX分割字符串
SELECT 
    SUBSTRING_INDEX('apple,banana,orange', ',', 1) AS part1,
    SUBSTRING_INDEX(SUBSTRING_INDEX('apple,banana,orange', ',', 2), ',', -1) AS part2,
    SUBSTRING_INDEX('apple,banana,orange', ',', -1) AS part3;

-- 使用FIND_IN_SET查找特定值
SELECT * FROM table WHERE FIND_IN_SET('banana', 'apple,banana,orange');

-- 自定义SPLIT_STR函数
DELIMITER $$
CREATE FUNCTION SPLIT_STR(x VARCHAR(255), delim VARCHAR(12), pos INT)
RETURNS VARCHAR(255)
DETERMINISTIC
BEGIN
    RETURN REPLACE(SUBSTRING(SUBSTRING_INDEX(x, delim, pos),
           LENGTH(SUBSTRING_INDEX(x, delim, pos - 1)) + 1),
           delim, '');
END$$
DELIMITER ;

-- 使用自定义函数分割字符串
SELECT SPLIT_STR('apple,banana,orange', ',', 2);

参考链接

通过以上方法，可以灵活地处理MySQL中的字符串分割需求，并根据具体场景选择最优的解决方案。

页面内容是否对你有帮助？

有帮助

没帮助

相关·内容

对比Pandas，轻松理解MySQL分组聚合的实现原理

小小明，「凹凸数据」专栏作者，Pandas数据处理专家，致力于帮助无数数据从业者解决数据处理难题。

03

分布式 | 如何通过 dble 的 split 功能，快速地将数据导入到 dble 中

当旧业务需要改造为基于 dble 的分布式业务时，会面临已有历史数据的拆分和导入问题，dble 支持的导入导出方式有多种，具体详见文档3.11.1，本次我们介绍的 split 功能可以理解为导入过程加速器，那它是怎么加速的呢？

04

MySQL 自定义 split 存储过程

MySQL 没有提供 split 函数，但可以自己建立一个存储过程，将具有固定分隔符的字符串转成多行。之所以不能使用自定义函数实现此功能，是因为 MySQL 的自定义函数自能返回标量值，不能返回多行结果集。

03

mysql存储过程下分割字符串函数

MySQL存储过程可以用于分割字符串，下面就为您详细介绍这种MySQL存储过程的用法，供您参考学习之用。现有一段字符串，如apple,banana,orange,pears,grape，要把它按照逗号(,)分割成： apple banana orange pears grape 然后使用where in()方法可以查询。

02

Python获取系统信息的代码

import os,inspect,socket,time,pymysql num = 0 class Mysql: def init(self,host,user,password,db): self.cnn = pymysql.connect(host=host,user=user, passwd=password, db=db, charset='utf8') self.cur= self.cnn.cursor() def run(self,sql):

03

Python获取系统信息的代码

import os,inspect,socket,time,pymysql num = 0 class Mysql: def init(self,host,user,password,db): self.cnn = pymysql.connect(host=host,user=user, passwd=password, db=db, charset='utf8') self.cur= self.cnn.cursor() def run(self,sql):

01

hive sql语句和mysql用法区别存档

mysql和hive版本： mysql版本：5.6.17 hive版本：2.1.1

02

MySQL字符串的合并及拆分

按照指定字符进行合并或拆分是经常碰到的场景，MySQL在合并的写法上比较简单，但是按指定字符拆分相对比较麻烦一点（也就是要多写一些字符）。本文将举例演示如何进行按照指定字符合并及拆分。

01

分析 Google Cloud Spanner 的架构

在2005、2006年期间，谷歌内部大规模使用了 MySQL 数据库。其中Google Adwords （谷歌广告部门）使用了 90 多个 MySQL Shards（分片）集群方案存储数据，是谷歌内部使用 MySQL 数据库的最大的部门之一。由于系统维护的原因，谷歌广告部门重新规划了 MySQL 集群，整个过程花了 2 年时间。因为谷歌知道它们的数据增长的非常快，再使用 MySQL 这类数据库到未来的某个时刻会非常痛苦。这就是 Spanner 的诞生原因。

01

MySQL8.0 InnoDB并行查询特性

MySQL经过多年的发展已然成为最流行的数据库，广泛用于互联网行业，并逐步向各个传统行业渗透。之所以流行，一方面是其优秀的高并发事务处理的能力，另一方面也得益于 MySQL 丰富的生态。MySQL 在处理 OLTP 场景下的短查询效果很好，但对于复杂大查询则能力有限。最直接一点就是，对于一个 SQL 语句，MySQL 最多只能使用一个 CPU 核来处理，在这种场景下无法发挥主机CPU多核的能力。MySQL 没有停滞不前，一直在发展，新推出的 8.0.14 版本第一次引入了并行查询特性，使得check table和select count(*) 类型的语句性能成倍提升。虽然目前使用场景还比较有限，但后续的发展值得期待。

02

Hadoop学习笔记—18.Sqoop框架学习

Hadoop正成为企业用于大数据分析的最热门选择，但想将你的数据移植过去并不容易。Apache Sqoop正在加紧帮助客户将重要数据从数据库移到Hadoop。随着Hadoop和关系型数据库之间的数据移动渐渐变成一个标准的流程，云管理员们能够利用Sqoop的并行批量数据加载能力来简化这一流程，降低编写自定义数据加载脚本的需求。

02

python练习题-员工信息表

周末大作业：实现员工信息表文件存储格式如下： id，name，age，phone，job 1,Alex,22,13651054608,IT 2,Egon,23,13304320533,Tearcher 3,nezha,25,1333235322,IT

01

利用Sqoop实现HDFS的数据与MySQL数据的互导

注意：查询语句必须包含where条件，即使不需要where条件，也需要写上"where $CONDITIONS"来表示没有select语句没有where条件

02

使用pt-fifo-split 工具往mysql插入海量数据

http://www.cnblogs.com/chenny7/p/4253337.html

02

Ambari方式安装Hadoop的Hive组件遇到的问题

最近在部署Hadoop，我发现了ambari工具部署hadoop的hive 组件的一个问题，不知道其他人遇到过没有。问题描述：通过ambari工具搭建了hadoop2.0完全分布式集群。在测试hive的时候，按照官方文档里的说明通过下面命令检查根目录的时候：总是报错无法连接mysql。（java.sql.SQLException: Access denied foruser 'hive'@'hdb3.yc.com'(using password: YES)）

02

第五章更换cdh版本，hive的安装使用，原理讲解

这里由于小编的这里在安装hive时，由于出现了启动hive时出现了和hadoop的版本不一致的原因，并且始终没有解决，所以就改变策略使用cdh版本的hadoop和hive.因为cdh版本的比较系统，兼容性好。因此要重新安装了。

02

高度伪造的爬虫&&X-Forwarded-For伪造ip跳过ip限制

针对需要大量代理ip的R××项目，采用伪造式的请求头跳过验证码和每日请求次数限制，现在针对请求做详细的拟人化，让对面更难以察觉。如有不足多多指教。项目最新完整代码放在github上：因为目前正在运作项目完结后公开，下文中有可运行代码

02

MySQL系统运行状态实时监控(python版本)

昨天的文章，用shell写了一个简单的MySQL系统运行状态实时监控的模版，《MySQL系统运行状态实时监控(shell版本)》，对于这种操作，任何语言都可以完成，今儿就用python写一下，写的不优雅的地方，请各位指正。

01

在MYSQL里面再连接MYSQL

运维的时候有时候需要连接多个mysql, 一般是选用多个窗口来做, 当然也有图形化的客户端软件.

05

（5）FlinkSQL将socket数据写入到mysql方式二

public static void main(String[] args) throws Exception { StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.setParallelism(1); StreamTableEnvironment tableEnv = StreamTableEnvironment.c

02

sqoop命令参数参考说明及案例示例

3.全量导入(将数据从mysql导入到hive,hive表不存在,导入时自动创建hive表)

04

基于Python和Xtrbackup的自动化备份与还原实现

xtrabackup是一个MySQL备份还原的常用工具，实际使用过程应该都是shell或者Python封装的自动化脚本，尤其是备份。对还原来说，对于基于完整和增量备份的还原，还原差异备份需要指定增量备份等等一系列容易出错的手工操作，以及binlog的还原等，如果纯手工操作的话非常麻烦。即便是你记性非常好，对xtrabackup非常熟悉，纯手工操作的话，非常容易出错，其实也上网找过，还原没有发现太好用的自动化还原脚本。于是就自己用Python封装了xtrabackup备份和还原的过程，可以做到自动化备份，基于时间点的自动化还原等等。

01

HBase学习和使用

版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。

03

[1219]mysql自定义函数split_part、split_last

关键字delimiter的使用： delimiter是mysql分隔符。在mysqlclient中分隔符默认是分号（；）。假设一次输入的语句较多，而且语句中间有分号，这时须要新指定一个特殊的分隔符。在前一篇中有设置mysql的触发器时使用样例

03

【MySQL基础】Mysql截取字符串split函数的实现以及使用范例

日前，统计数据的时候发现需要字符串分隔，MySql中并没有类似Java的split函数，但是我们可以利用length()函数、replace() 2个函数创建一个自定义的split函数，sql很简单，该函数定义也是DETERMINISTIC, NO SQL, or READS SQL DATA in its declaration and binary logging的错误解决方案之一。 split函数:

02

sqoop原理

sqoop,各位看官基本上都了解或者听说过，小二就不进行废话了。另外基于国内大部分用的为CDH，小二就想说一点：CDH中的sqoop2其实是apace版的sqoop1，聪明的看官不要被表面所迷惑了.

01

[开发]Python实现运维监控服务器硬

今天通过使用Python开发针对服务器硬件运行状态的监控，简单了解下在虚拟环境中的运维监控的实现，算是给全面研究云计算开一个头。

03

Python实现农历生日提醒功能

发现实现这个需求最主要的在获取农历这一块，后边两个不是什么巨大挑战。遂查阅一番资料，发现数据库可以实现阳历转阴历功能。在数据库这一块，我是在是小菜，看不懂存储过程。蛋疼！直接放弃改用其他思路。思考了许久，想到可以通过爬虫爬取现成的日历信息，存库再进行匹配。所以，现在思路如下：

01

Sqoop集群环境搭建 | MySQL数据导出HDFS测试

Apache Sqoop是在Hadoop生态体系和*RDBMS体系之间传送数据的一种工具。来自于Apache软件基金会提供。，主要用于在Hadoop(Hive)与传统的数据库间进行数据的传递，可以将一个关系型数据库中的数据导进到Hadoop的HDFS中，也可以将HDFS的数据导进到关系型数据库中。

02

来看看一个大二学生的Spark练习题

23. 总成绩大于150分，且数学大于等于70，且年龄大于等于19岁的学生的平均成绩是多少？

06

sqoop数据导入总结

这是黄文辉同学处女作，大家支持！其他相关文章：元数据概念 Sqoop主要用来在Hadoop(HDFS)和关系数据库中传递数据,使用Sqoop,我们可以方便地将数据从关系型数据库导入HDFS,或者将数据从关系型数据库导入HDFS,或者将从HDFS导出到关系型数据库. 从数据库导入数据 import命令参数说明参数说明--append将数据追加到HDFS上一个已存在的数据集上--as-avrodatafile将数据导入到Avro数据文件--as-sequencefile将数据导入到SequenceFile

08

I-team 博客全文检索 Elasticsearch 实战

一直觉得博客缺点东西，最近还是发现了，当博客慢慢多起来的时候想要找一篇之前写的博客很是麻烦，于是作为后端开发的楼主觉得自己动手丰衣足食，也就有了这次博客全文检索功能Elasticsearch实战，这里还要感谢一下‘辉哥’赞助的一台服务器。

01

Flink CDC 2.0 数据处理流程全面解析

8月份 FlinkCDC 发布2.0.0版本，相较于1.0版本，在全量读取阶段支持分布式读取、支持checkpoint，且在全量 + 增量读取的过程在不锁表的情况下保障数据一致性。

02

使用python对mysql主从进行监控

*/5 * * * * source ~/.bashrc && /usr/bin/python /lvdata/send_msg.py

02

爬虫练习-豆瓣读书

昨晚使用不熟悉的xpath语法解析百度新闻页面碰到了好多坑，今天继续通过简单的豆瓣图书进行练习

04

python 3 使用pymysql 连

pymysql 连接Inception ，在判断版本时会出现value error 问题。

01

【万字长文】Flink cdc源码精讲(推荐收藏)

上面内容主要是以构建source所需要的参数为主,具体我们进入到DebeziumSourceFunction中看看具体实现

02

Sqoop快速入门系列(2) | Sqoop数据导入与导出

在Sqoop中，“导入”概念指：从非大数据集群（RDBMS）向大数据集群（HDFS，HIVE，HBASE）中传输数据，叫做：导入，即使用import关键字。

02

python3 自动打印出最新版本执行的mysql2redis实例

mysql2redis是一个可以在mysql中执行redis命令的第三方插件，昨天在用它调用命令LTRIM时没有效果：

01

groovy爬虫练习之——企业信息

获取数据的方法依然采取了regex正则匹配的方法，请求框架采用了java，爬虫语言是groovy，本地拼接好sql语句，发送到mysql服务端，完成存储。代码如下： package com.fan import com.fantest.httpclient.FanLibrary import com.fantest.mysql.MySqlTest import com.fantest.utils.Regex import net.sf.json.JSONObject class Company ext

01

【Spark篇】---SparkSQL初始和创建DataFrame的几种方式

Hive是Shark的前身，Shark是SparkSQL的前身,SparkSQL产生的根本原因是其完全脱离了Hive的限制。

01

percona-toolkit学习笔记（七）

pt-fifo-split读取大文件中的数据并打印到fifo文件，每次达到指定行数就往fifo文件中打印一个EOF字符，读取完成以后，关闭掉fifo文件并移走，然后重建fifo文件，打印更多的行。这样可以保证你每次读取的时候都能读取到制定的行数直到读取完成。注意此工具只能工作在类unix操作系统。这个程序对大文件的数据导入数据库非常有用，具体参考：https://www.percona.com/blog/2008/07/03/how-to-load-large-files-safely-into-innodb-with-load-data-infile/

03

python 实现端口连通性检测

在zabbix 中加入对表中数据的监控。在zabbix 的mysql 模板中加入Balant 的监控项，也可以加入图像，我们最后的结果是要展示在grafana 上进行展示。为1就说明应用端口是正常运行。

01

分布式ETL工具Sqoop实践

3、在/root/sqoop_file目录编写配置文件list_dbs.conf，减少重复参数配置。

01

（4）FlinkSQL将socket数据写入到mysql方式一

本章节主要演示从socket接收数据，通过滚动窗口每30秒运算一次窗口数据，然后将结果写入Mysql数据库

02

Python爬虫之Xpath学习问题解决用xpath方法爬取豆瓣图书top250分析总结

问题解决这是我昨天发的简书python爬虫之豆瓣音乐top250大牛们解决了一大部分的问题 1 MySQL报错问题字段长度设置太小，说着也很奇怪，我用的vachar(20)都说小了，哎，后面建表干

04

码农技术炒股之路——数据库管理器、正则表达式管理器

我选用的数据库是Mysql。选用它是因为其可以满足我的需求，而且资料多。因为作为第三方工具，难免有一些配置问题。所以本文也会讲解一些和Mysql配置及开发相关的问题。（转载请指明出于breaksoftware的csdn博客）

02

通过celery提高crontab配置效率

今天在接入备份任务配置的时候也是一波三折，解决了业务元数据的问题，也逐步熟悉了业务，对于现有的备份情况会越来越有把握。

02

Flink 实践教程：进阶9-自定义表值函数（UDTF）

流计算 Oceanus 是大数据产品生态体系的实时化分析利器，是基于 Apache Flink 构建的具备一站开发、无缝连接、亚秒延时、低廉成本、安全稳定等特点的企业级实时大数据分析平台。流计算 Oceanus 以实现企业数据价值最大化为目标，加速企业实时化数字化的建设进程。

04

php结合redis实现秒杀功能

第一种，简单实现 <?php $conn=mysql_connect("localhost","test","123456"); if(!$conn){ echo "connect faile

00

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云

扫码加入开发者社群

相关资讯

热门标签

活动推荐

运营活动

活动名称

广告关闭