LongSheng | Page 93

mysql json 使用类型查询函数

一,对记录的操作 1.创建有json字段的表

1 2	-- 创建表 CREATE TABLE t_json(id INT PRIMARY KEY, sname VARCHAR(20) , info JSON);

2.插入记录

-- 插入含有json数组的记录

INSERT INTO t_json(id,sname,info) VALUES( 1, 'name1', JSON_ARRAY(1, "abc", NULL, TRUE, CURTIME()));

-- 插入含有json对象的记录

INSERT INTO t_json(id,sname,info) VALUES( 2, 'name2', JSON_OBJECT("age", 20, "time", now()));

INSERT INTO t_json(id,sname,info) VALUES( 3, 'name3', '{"age":20, "time":"2018-07-14 10:52:00"}');

3.查询记录

-- 查询记录

SELECT sname,JSON_EXTRACT(info,'$.age') FROM t_json;

SELECT sname,info->'$.age' FROM t_json;

-- 查询key

SELECT id,json_keys(info) FROM t_json;

4.修改记录

-- 增加键

UPDATE t_json SET info = json_set(info,'$.ip','192.168.1.1') WHERE id = 2;

-- 变更值

UPDATE t_json SET info = json_set(info,'$.ip','192.168.1.2') WHERE id = 2;

-- 删除键

UPDATE t_json SET info = json_remove(info,'$.ip') WHERE id = 2;

二,创建json值函数 1.JSON_ARRAY 生成json数组

-- JSON_ARRAY(val1,val2,val3...)

-- 生成一个包含指定元素的json数组。

SELECT JSON_ARRAY(1, "abc", NULL, TRUE, CURTIME()); -- [1, "abc", null, true, "10:37:08.000000"]

2.JSON_OBJECT 生成json对象

-- JSON_OBJECT(key1,val1,key2,val2...)

-- 生成一个包含指定K-V对的json object。如果有key为NULL或参数个数为奇数，则抛错。

SELECT JSON_OBJECT('age', 20, 'time', now()); -- {"id": 87, "name": "carrot"}

3.JSON_QUOTE 加"号

-- JSON_QUOTE(json_val)

-- 将json_val用"号括起来。

SELECT JSON_QUOTE('[1,2,3]'); -- "[1,2,3]"

三,搜索json值函数 1.JSON_CONTAINS 指定数据是否存在

set @j = '{"a": 1, "b": 2, "c": {"d": 4}}';

-- JSON_CONTAINS(json_doc, val[, path])

-- 查询json文档是否在指定path包含指定的数据，包含则返回1，否则返回0。如果有参数为NULL或path不存在，则返回NULL。

SELECT JSON_CONTAINS(@j, '4', '$.c.d'); -- 1

2.JSON_CONTAINS_PATH 指定路径是否存在

-- JSON_CONTAINS_PATH(json_doc, one_or_all, path[, path] ...)

-- 查询是否存在指定路径，存在则返回1，否则返回0。如果有参数为NULL，则返回NULL。

-- one_or_all只能取值"one"或"all"，one表示只要有一个存在即可；all表示所有的都存在才行。

SELECT JSON_CONTAINS_PATH(@j, 'one', '$.a', '$.e'); -- 1

SELECT JSON_CONTAINS_PATH(@j, 'all', '$.a', '$.c.d'); -- 1

3.JSON_EXTRACT 查找所有指定数据

-- JSON_EXTRACT(json_doc, path[, path] ...)

-- 从json文档里抽取数据。如果有参数有NULL或path不存在，则返回NULL。如果抽取出多个path，则返回的数据封闭在一个json array里。

set @j2 = '[10, 20, [30, 40]]';

SELECT JSON_EXTRACT('[10, 20, [30, 40]]', '$[1]'); -- 20

SELECT JSON_EXTRACT('[10, 20, [30, 40]]', '$[1]', '$[0]'); -- [20, 10]

SELECT JSON_EXTRACT('[10, 20, [30, 40]]', '$[2][*]'); -- [30, 40]

4.JSON_KEYS 查找所有指定键值

-- JSON_KEYS(json_doc[, path])

-- 获取json文档在指定路径下的所有键值，返回一个json array。如果有参数为NULL或path不存在，则返回NULL。

SELECT JSON_KEYS('{"a": 1, "b": {"c": 30}}'); -- ["a", "b"]

SELECT JSON_KEYS('{"a": 1, "b": {"c": 30}}', '$.b'); -- ["c"]

SELECT id,json_keys(info) FROM t_json;

5.JSON_SEARCH 查找所有指定值的位置

-- JSON_SEARCH(json_doc, one_or_all, search_str[, escape_char[, path] ...])

-- 查询包含指定字符串的paths，并作为一个json array返回。如果有参数为NUL或path不存在，则返回NULL。

-- one_or_all："one"表示查询到一个即返回；"all"表示查询所有。

-- search_str：要查询的字符串。可以用LIKE里的'%'或‘_’匹配。

-- path：在指定path下查。

SET @j3 = '["abc", [{"k": "10"}, "def"], {"x":"abc"}, {"y":"bcd"}]';

SELECT JSON_SEARCH(@j3, 'one', 'abc'); -- "$[0]"

SELECT JSON_SEARCH(@j3, 'all', 'abc'); -- ["$[0]", "$[2].x"]

SELECT JSON_SEARCH(@j3, 'all', 'abc', NULL, '$[2]'); -- "$[2].x"

SELECT JSON_SEARCH(@j3, 'all', '10'); -- "$[1][0].k"

SELECT JSON_SEARCH(@j3, 'all', '%b%'); -- ["$[0]", "$[2].x", "$[3].y"]

SELECT JSON_SEARCH(@j3, 'all', '%b%', NULL, '$[2]'); -- "$[2].x"

四,修改json值函数 1.JSON_ARRAY_APPEND 指定位置追加数组元素

-- JSON_ARRAY_APPEND(json_doc, path, val[, path, val] ...)

-- 在指定path的json array尾部追加val。如果指定path是一个json object，则将其封装成一个json array再追加。如果有参数为NULL，则返回NULL。

SET @j4 = '["a", ["b", "c"], "d"]';

-- SELECT JSON_ARRAY_APPEND(@j4, '$[1][0]', 3); -- ["a", [["b", 3], "c"], "d"]

SET @j5 = '{"a": 1, "b": [2, 3], "c": 4}';

SELECT JSON_ARRAY_APPEND(@j5, '$.b', 'x'); -- {"a": 1, "b": [2, 3, "x"], "c": 4}

SELECT JSON_ARRAY_APPEND(@j5, '$.c', 'y'); -- {"a": 1, "b": [2, 3], "c": [4, "y"]}

SELECT JSON_ARRAY_APPEND(@j5, '$', 'z'); -- [{"a": 1, "b": [2, 3], "c": 4}, "z"]

2.JSON_ARRAY_INSERT 指定位置插入数组元素

-- JSON_ARRAY_INSERT(json_doc, path, val[, path, val] ...)

-- 在path指定的json array元素插入val，原位置及以右的元素顺次右移。如果path指定的数据非json array元素，则略过此val；如果指定的元素下标超过json array的长度，则插入尾部。

SET @j6 = '["a", {"b": [1, 2]}, [3, 4]]';

SELECT JSON_ARRAY_INSERT(@j6, '$[1]', 'x'); -- ["a", "x", {"b": [1, 2]}, [3, 4]]

SELECT JSON_ARRAY_INSERT(@j6, '$[100]', 'x'); -- ["a", {"b": [1, 2]}, [3, 4], "x"]

SELECT JSON_ARRAY_INSERT(@j6, '$[1].b[0]', 'x'); -- ["a", {"b": ["x", 1, 2]}, [3, 4]]

SELECT JSON_ARRAY_INSERT(@j6, '$[0]', 'x', '$[3][1]', 'y'); -- ["x", "a", {"b": [1, 2]}, [3, "y", 4]]

3.JSON_INSERT 指定位置插入

-- JSON_INSERT(json_doc, path, val[, path, val] ...)

-- 在指定path下插入数据，如果path已存在，则忽略此val（不存在才插入）。

SET @j7 = '{ "a": 1, "b": [2, 3]}';

SELECT JSON_INSERT(@j7, '$.a', 10, '$.c', '[true, false]'); -- {"a": 1, "b": [2, 3], "c": "[true, false]"}

4.JSON_REPLACE 指定位置替换

-- JSON_REPLACE(json_doc, path, val[, path, val] ...)

-- 替换指定路径的数据，如果某个路径不存在则略过（存在才替换）。如果有参数为NULL，则返回NULL。

SELECT JSON_REPLACE(@j7, '$.a', 10, '$.c', '[true, false]'); -- {"a": 10, "b": [2, 3]}

5.JSON_SET 指定位置设置

-- JSON_SET(json_doc, path, val[, path, val] ...)

-- 设置指定路径的数据（不管是否存在）。如果有参数为NULL，则返回NULL。

SELECT JSON_SET(@j7, '$.a', 10, '$.c', '[true, false]'); -- {"a": 10, "b": [2, 3], "c": "[true, false]"}

6.JSON_MERGE 合并

-- JSON_MERGE(json_doc, json_doc[, json_doc] ...)

-- merge多个json文档。规则如下：

-- 如果都是json array，则结果自动merge为一个json array；

-- 如果都是json object，则结果自动merge为一个json object；

-- 如果有多种类型，则将非json array的元素封装成json array再按照规则一进行mege。

SELECT JSON_MERGE('[1, 2]', '[true, false]'); -- [1, 2, true, false]

SELECT JSON_MERGE('{"name": "x"}', '{"id": 47}'); -- {"id": 47, "name": "x"}

SELECT JSON_MERGE('1', 'true'); -- [1, true]

SELECT JSON_MERGE('[1, 2]', '{"id": 47}'); -- [1, 2, {"id": 47}]

7.JSON_REMOVE 指定位置移除

-- JSON_REMOVE(json_doc, path[, path] ...)

-- 移除指定路径的数据，如果某个路径不存在则略过此路径。如果有参数为NULL，则返回NULL。

SET @j8 = '["a", ["b", "c"], "d"]';

SELECT JSON_REMOVE(@j8, '$[1]'); -- ["a", "d"]

8.JSON_UNQUOTE 去"号

-- JSON_UNQUOTE(val)

-- 去掉val的引号。如果val为NULL，则返回NULL。

SELECT JSON_UNQUOTE("\"123\""); -- 123

五,返回json值属性的函数 1.JSON_DEPTH 深度

-- JSON_DEPTH(json_doc)

-- 获取json文档的深度。如果参数为NULL，则返回NULL。

-- 空的json array、json object或标量的深度为1。

SELECT JSON_DEPTH('{}'), JSON_DEPTH('[]'), JSON_DEPTH('true'); -- 1 1 1

SELECT JSON_DEPTH('[10, 20]'), JSON_DEPTH('[[], {}]'); -- 2 2

SELECT JSON_DEPTH('[10, {"a": 20}]'); -- 3

2.JSON_LENGTH 长度

-- JSON_LENGTH(json_doc[, path])

-- 获取指定路径下的长度。如果参数为NULL，则返回NULL。　

-- 长度的计算规则：

-- 标量的长度为1；

-- json array的长度为元素的个数；

-- json object的长度为key的个数。

SELECT JSON_LENGTH('[1, 2, {"a": 3}]'); -- 3

SELECT JSON_LENGTH('{"a": 1, "b": {"c": 30}}'); -- 2

SELECT JSON_LENGTH('{"a": 1, "b": {"c": 30}}', '$.b'); -- 1

[…]

龙生 13 Jun 2021

View Details

mysql字符串拆分实现split功能

【0】需求【0.1】需求描述数据库中 num字段值为：实现的效果：需要将一行数据变成多行【0.2】实现的SQL

SELECT

SUBSTRING_INDEX(SUBSTRING_INDEX('7654,7698,7782,7788',',',help_topic_id+1),',',-1) AS num

FROM

mysql.help_topic

WHERE

help_topic_id < LENGTH('7654,7698,7782,7788')-LENGTH(REPLACE('7654,7698,7782,7788',',',''))+1

涉及的知识点【1】字符串拆分： SUBSTRING_INDEX（str, delim, count）参数解说解释 str 　　　　需要拆分的字符串 delim 　　分隔符，通过某字符进行拆分 count 　　当 count 为正数，取第 n 个分隔符之前的所有字符；当 count 为负数，取倒数第 n 个分隔符之后的所有字符。举例

（1）获取第2个以逗号为分隔符之前的所有字符。

SELECT SUBSTRING_INDEX('7654,7698,7782,7788',',',2);

（2）获取最后一个到倒数第2个以逗号分隔符之后的所有字符

SELECT SUBSTRING_INDEX('7654,7698,7782,7788',',',-2);

所以，我们的核心代码中的 -1 ，就是获取以逗号为分隔符的最后一个值；也就是7788 【2】替换函数：replace( str, from_str, to_str) 参数名　　解释 str 　　　　需要进行替换的字符串 from_str 　　需要被替换的字符串 to_str 　　　需要替换的字符串 2. 举例

（1）将分隔符逗号替换为空。

SELECT REPLACE('7654,7698,7782,7788',',','');

【3】获取字符串长度：LENGTH( str ) 参数名　　解释 str 　　　　需要计算长度的字符串举例

（1）获取 ‘7654,7698,7782,7788’ 字符串的长度

SELECT LENGTH('7654,7698,7782,7788')

【4】实现的原理解析【4.0】实现SQL 需要解析的SQL

SELECT

SUBSTRING_INDEX(SUBSTRING_INDEX('7654,7698,7782,7788',',',help_topic_id+1),',',-1) AS num

FROM

mysql.help_topic

WHERE

help_topic_id < LENGTH('7654,7698,7782,7788')-LENGTH(REPLACE('7654,7698,7782,7788',',',''))+1

此处利用 mysql 库的 help_topic 表的 help_topic_id 来作为变量，因为 help_topic_id 是自增的，当然也可以用其他表的自增字段辅助。 help_topic 表：注意，这个辅助表的ID最大长度只有642；如果过长的字符串，可能需要借助其他自增的辅助表（可以是现有表，也可以自己造一个 1,2,3,4 递增的行即可） […]

龙生 11 Jun 2021

View Details

max_allowed_packet设置问题

最近在运行的项目出现了一个线上事故，有人反映商城的东西下不了单了，到后台看了一下，果然报了一个错 Cause: com.mysql.jdbc.PacketTooBigException: Packet for query is too large (1046 > 1024). You can change this value on the server by setting the max_allowed_packet' variable.; ]; Packet for query is too large (1046 > 1024). You can change this value on the server by setting the max_allowed_packet' variable.; nested exception is com.mysql.jdbc.PacketTooBigException: Packet for query is too large (1046 > 1024). You can change this value on the server by setting the max_allowed_packet' variable. 其实上面的报错信息就给出了解决方案了，原来mysql根据配置文件会限制server接受的数据包大小。如果一次插入数据库中的数据太大的话就会失败，官方也有这方面的介绍官方介绍用命令行查看show VARIABLES like '%max_allowed_packet%';果然max_allowed_packet太小了解决方法 1、修改配置文件（推荐）在mysql中的my.ini文件中（在programdata隐藏文件中），修改max_allowed_packet的值比如：max_allowed_packet=128M 然后重启mysql就可以 2、命令行中设置 set global max_allowed_packet = […]

龙生 09 Jun 2021

View Details

带你入门consul

consul consul用于微服务下的服务治理，主要特点有：服务发现、服务配置、健康检查、键值存储、安全服务通信、多数据中心等。什么叫服务治理发现？起初我们的服务比较单一，各服务之间通过接口就能访问。后面服务越来越复杂出现了分布式，为了不引起单点问题，必然是多服务部署，如果还用原来的方式直接连接，那么在某个服务挂掉或者修改了信息，就会导致连接失败。如果连接端能够不去关心具体的服务配置，他只要连接到那个服务，后续的工作由其它服务保证，包括负载均衡、健康检查等，保证总有可用的连接那就行了，consul就是做这个的，当然，它的功能远不止这些，这里只是以服务发现为例。与它同类的东西，还有Eureka、zooKeeper、etcd等也能做这些事，说不上谁好谁坏，看场景挑合适的吧，不过Eureka现在已经闭源了，这个还是建议不要去用这个了。 consul下载 consule的安装超级简单，去官方下载地址Download ，找到自已对应系统的压缩包，解压后里面就一个文件consul, 将这个文件放到你的PATH中，就能直接用了。验证下安装成功没有, 看到下面的提示就行了。

$ consul version

Consul v1.7.2

Protocol 2 spoken by default, understands 2 to 3 (agent will automatically use protocol >2 when speaking to compatible agents)

consul的CLI操作 consul提供了cli的命令操作，如启动代理、键值存储、注册／注销服务、加入集群等，这个consul提供的HTTP的API操作也是一样的，只是这里都是shell的操作。

$ consul

Usage: consul [--version] [--help] <command> [<args>]

Available commands are:

acl Interact with Consul's ACLs

agent Runs a Consul agent

catalog Interact with the catalog

config Interact with Consul's Centralized Configurations

connect Interact with Consul Connect

debug Records a debugging archive for operators

event Fire a new event

exec Executes a command on Consul nodes

force-leave Forces a member of the cluster to enter the "left" state

info Provides debugging information for operators.

intention Interact with Connect service intentions

join Tell Consul agent to join cluster

keygen Generates a new encryption key

keyring Manages gossip layer encryption keys

kv Interact with the key-value store

leave Gracefully leaves the Consul cluster and shuts down

lock Execute a command holding a lock

logout Destroy a Consul token created with login

maint Controls node or service maintenance mode

members Lists the members of a Consul cluster

monitor Stream logs from a Consul agent

operator Provides cluster-level tools for Consul operators

reload Triggers the agent to reload configuration files

rtt Estimates network round trip time between nodes

services Interact with services

snapshot Saves, restores and inspects snapshots of Consul server state

tls Builtin helpers for creating CAs and certificates

validate Validate config files/directories

version Prints the Consul version

watch Watch for changes in Consul

Agent启动 consul是通过Agent来运行的，Agent又分为Server Agent和Client Agent两种类型，这两类型基本上是没区别的，Server Agent会将服务的消息存储起来，至少要启动一个Server Agent，为了防止单点，集群环境中推荐3-5个。 Client Agent主要用于注销服务、健康检查及转发Server Agent的查询等，它相当于一个代理，所以他必须在集群的每台主机上都要运行。先看下Agent的常用配置

1	$ consul agent --help

--server 定义运行server agent --data-dir 配置consul数据存储路径 --bootstrap-expect ：期望的server节点数目，consul一直等到指定sever数目的时候才会引导整个集群 --bind：该地址用来在集群内部的通讯，集群内的所有节点到地址都必须是可达的，默认是0.0.0.0 --node：节点在集群中的名称，在一个集群中必须是唯一的，默认是该节点的主机名 --ui： web的管理ui,查看服务和节点 --config-dir：配置文件目录，所有以.json结尾的文件都会被加载，可以是服务或consul自身的配置 --client：提供HTTP、DNS、RPC等服务，默认是127.0.0.1,不对外提供服务，如果需要则改成0.0.0.0 我本地没有虚拟机，也没用Docker操作，所以，如果要同时启动Server和Client的话，我就用的改端口的方式，当然生产环境肯定就没有这个了，它都是一台机器启动一个Agent, 这里只是测试用的。启动一个Server Agent

1	$ consul agent --server=true --ui=true --data-dir=/tmp/consul --node=server1 --dev

上面的 --server表示以server方式，--ui 会开启一个web ui管理界面, --dev 表示开发者模式，不需要ACL验证。不然那个web ui的打不开会报没有权限。

==> Starting Consul agent...

Version: 'v1.7.2'

Node ID: 'f6272369-098a-1412-ed86-6e2076c1e5e4'

Node name: 'server1'

Datacenter: 'dc1' (Segment: '<all>')

Server: true (Bootstrap: false)

Client Addr: [127.0.0.1] (HTTP: 8500, HTTPS: -1, gRPC: 8502, DNS: 8600)

Cluster Addr: 127.0.0.1 (LAN: 8301, WAN: 8302)

Encrypt: Gossip: false, TLS-Outgoing: false, TLS-Incoming: false, Auto-Encrypt-TLS: false

==> Log data will now stream in as it occurs:

2020-04-01T14:28:52.579+0800 [DEBUG] agent.tlsutil: Update: version=1

2020-04-01T14:28:52.580+0800 [DEBUG] agent.tlsutil: OutgoingRPCWrapper: version=1

2020-04-01T14:28:52.580+0800 [INFO] agent.server.raft: initial configuration: index=1 servers="[{Suffrage:Voter ID:f6272369-098a-1412-ed86-6e2076c1e5e4 Address:127.0.0.1:8300}]"

2020-04-01T14:28:52.580+0800 [INFO] agent.server.raft: entering follower state: follower="Node at 127.0.0.1:8300 [Follower]" leader=

2020-04-01T14:28:52.581+0800 [INFO] agent.server.serf.wan: serf: EventMemberJoin: server1.dc1 127.0.0.1

2020-04-01T14:28:52.581+0800 [INFO] agent.server.serf.lan: serf: EventMemberJoin: server1 127.0.0.1

2020-04-01T14:28:52.581+0800 [INFO] agent.server: Adding LAN server: server="server1 (Addr: tcp/127.0.0.1:8300) (DC: dc1)"

2020-04-01T14:28:52.581+0800 [INFO] agent.server: Handled event for server in area: event=member-join server=server1.dc1 area=wan

2020-04-01T14:28:52.581+0800 [INFO] agent: Started DNS server: address=127.0.0.1:8600 network=tcp

2020-04-01T14:28:52.582+0800 [INFO] agent: Started DNS server: address=127.0.0.1:8600 network=udp

2020-04-01T14:28:52.582+0800 [INFO] agent: Started HTTP server: address=127.0.0.1:8500 network=tcp

2020-04-01T14:28:52.582+0800 [INFO] agent: Started gRPC server: address=127.0.0.1:8502 network=tcp

2020-04-01T14:28:52.582+0800 [INFO] agent: started state syncer

==> Consul agent running!

启动Client Agent

1	$ consul agent --data-dir=/tmp/consul_client --join=127.0.0.1:8301 --serf-lan-port=8303 --serf-wan-port=8305 --dns-port=8601 --server-port=8304 --http-port=8503 --server=false --config-dir=./consul.d --enable-script-checks --node=client1

上面有一个--join表示加入到集群中，写server agent的地址就行。 config-dir的配置目录下面一个服务的配置

{

"service":{

"name":"web",

"tags":[

"local"

"port":80,

"check":{

"name":"ping",

"args":["/usr/bin/curl","-s", "http://localhost/"],

"interval":"10s"

}

上面的命令运行后，会启动一个名字为“web"的服务，并提供健康检查。

==> Starting Consul agent...

Version: 'v1.7.2'

Node ID: 'e1c8f283-f5c4-27e7-c29c-64666df1c52b'

Node name: 'client1'

Datacenter: 'dc1' (Segment: '')

Server: false (Bootstrap: false)

Client Addr: [127.0.0.1] (HTTP: 8503, HTTPS: -1, gRPC: -1, DNS: 8601)

Cluster Addr: 192.168.0.103 (LAN: 8303, WAN: 8305)

Encrypt: Gossip: false, TLS-Outgoing: false, TLS-Incoming: false, Auto-Encrypt-TLS: false

==> Log data will now stream in as it occurs:

2020-04-01T00:00:49.227+0800 [INFO] agent.client.serf.lan: serf: EventMemberJoin: client1 192.168.0.103

2020-04-01T00:00:49.231+0800 [INFO] agent: Started DNS server: address=127.0.0.1:8601 network=udp

2020-04-01T00:00:49.232+0800 [INFO] agent: Started DNS server: address=127.0.0.1:8601 network=tcp

2020-04-01T00:00:49.232+0800 [INFO] agent: Started HTTP server: address=127.0.0.1:8503 network=tcp

==> Joining cluster...

2020-04-01T00:00:49.232+0800 [INFO] agent: (LAN) joining: lan_addresses=[127.0.0.1:8301]

2020-04-01T00:00:49.233+0800 [WARN] agent.client.memberlist.lan: memberlist: Refuting a dead message (from: client1)

2020-04-01T00:00:49.233+0800 [INFO] agent.client.serf.lan: serf: EventMemberJoin: server1 127.0.0.1

2020-04-01T00:00:49.233+0800 [INFO] agent.client: adding server: server="server1 (Addr: tcp/127.0.0.1:8300) (DC: dc1)"

2020-04-01T00:00:49.233+0800 [INFO] agent: (LAN) joined: number_of_nodes=1

2020-04-01T00:00:49.233+0800 [INFO] agent: Join completed. Initial agents synced with: agent_count=1

2020-04-01T00:00:49.233+0800 [INFO] agent: started state syncer

==> Consul agent running!

2020-04-01T00:00:49.235+0800 [INFO] agent: Synced node info

2020-04-01T00:00:49.235+0800 [INFO] agent: Synced service: service=web

2020-04-01T00:00:53.316+0800 [INFO] agent: Synced check: check=service:web

查看下，启动的Agent

$ ./consul members

Node Address Status Type Build Protocol DC Segment

server1 127.0.0.1:8301 alive server 1.7.2 2 dc1 <all>

client1 127.0.0.1:8303 alive client 1.7.2 2 dc1 <default>

web管理界面可以查看服务的定义和节点，访问[web管理界面](http://127.0.0.1:8500/ui) HTTP API consul除了提供DNS外，还提供Http的操作，如注册服务、查看节点、查看服务信息等，一般都是通过API来操作的。如我上面定义的 "web"服务，通过下面的API查询，就能得到具体的IP地址和端口，这样就能直接连到那台服务了。其它更详情API操作，可以自已去参照官方的文档 API

$ curl http://127.0.0.1:8500/v1/catalog/service/web

[

{

"ID": "e1c8f283-f5c4-27e7-c29c-64666df1c52b",

"Node": "client1",

"Address": "127.0.0.1",

"Datacenter": "dc1",

"TaggedAddresses": {

"lan": "127.0.0.1",

"lan_ipv4": "127.0.0.1",

"wan": "127.0.0.1",

"wan_ipv4": "127.0.0.1"

"NodeMeta": {

"consul-network-segment": ""

"ServiceKind": "",

"ServiceID": "web",

"ServiceName": "web",

"ServiceTags": [

"local"

"ServiceAddress": "",

"ServiceWeights": {

"Passing": 1,

"Warning": 1

"ServiceMeta": {},

"ServicePort": 80,

"ServiceEnableTagOverride": false,

"ServiceProxy": {

"MeshGateway": {},

"Expose": {}

"ServiceConnect": {},

"CreateIndex": 15,

"ModifyIndex": 15

}

]

from:https://zhuanlan.zhihu.com/p/122340918

龙生 08 Jun 2021

View Details

MySQL show processlist说明

show processlist和show full processlist processlist命令的输出结果显示了有哪些线程在运行，不仅可以查看当前所有的连接数，还可以查看当前的连接状态帮助识别出有问题的查询语句等。如果是root帐号，能看到所有用户的当前连接。如果是其他普通帐号，则只能看到自己占用的连接。showprocesslist只能列出当前100条。如果想全部列出，可以使用SHOW FULL PROCESSLIST命令

mysql> show processlist;

+----+------+--------------------+------+---------+-------+-------+------------------+

+----+------+--------------------+------+---------+-------+-------+------------------+

| 2 | root | 192.168.100.1:7437 | test | Sleep | 8035 | | NULL |

| 3 | root | 192.168.100.1:7438 | NULL | Sleep | 24348 | | NULL |

| 5 | root | 192.168.100.1:7443 | NULL | Sleep | 24317 | | NULL |

| 7 | root | 192.168.100.1:7450 | test | Sleep | 24272 | | NULL |

+----+------+--------------------+------+---------+-------+-------+------------------+

6 rows in set

mysql> show full processlist;

+----+------+--------------------+------+---------+-------+-------+-----------------------+

+----+------+--------------------+------+---------+-------+-------+-----------------------+

| 2 | root | 192.168.100.1:7437 | test | Sleep | 8042 | | NULL |

| 3 | root | 192.168.100.1:7438 | NULL | Sleep | 24355 | | NULL |

| 5 | root | 192.168.100.1:7443 | NULL | Sleep | 24324 | | NULL |

| 7 | root | 192.168.100.1:7450 | test | Sleep | 24279 | | NULL |

+----+------+--------------------+------+---------+-------+-------+-----------------------+

6 rows in set

各个列的含义： ①.id列，用户登录mysql时，系统分配的"connection_id"，可以使用函数connection_id()查看 ②.user列，显示当前用户。如果不是root，这个命令就只显示用户权限范围的sql语句 ③.host列，显示这个语句是从哪个ip的哪个端口上发的，可以用来跟踪出现问题语句的用户 ④.db列，显示这个进程目前连接的是哪个数据库 ⑤.command列，显示当前连接的执行的命令，一般取值为休眠（sleep），查询（query），连接（connect）等 ⑥.time列，显示这个状态持续的时间，单位是秒 ⑦.state列，显示使用当前连接的sql语句的状态，很重要的列。state描述的是语句执行中的某一个状态。一个sql语句，以查询为例，可能需要经过copying to tmp table、sorting result、sending data等状态才可以完成 ⑧.info列，显示这个sql语句，是判断问题语句的一个重要依据在主从复制环境中，show processlist或show full processlist对于判断状态很有帮助，例如下面的state列： from:https://www.cnblogs.com/flzs/p/11044689.html

龙生 08 Jun 2021

View Details

mysql select into的用法

MySQL不支持Select Into语句直接备份表结构和数据,一些种方法可以代替,如下:

#MYSQL不支持:

Select * Into new_table_name from old_table_name; 这是sql server中的用法

#替代方法:

Create table new_table_name (Select * from old_table_name);

from:https://blog.csdn.net/zwldx/article/details/82227533

龙生 08 Jun 2021

View Details

git 如何取消add操作

可以直接使用命令 git reset HEAD 这个是整体回到上次一次操作绿字变红字(撤销add) 如果是某个文件回滚到上一次操作： git reset HEAD 文件名红字变无 (撤销没add修改) git checkout — 文件 from:https://www.cnblogs.com/jpfss/p/11888157.html

龙生 07 Jun 2021

View Details

MySql时间戳函数

参考链接：https://www.cnblogs.com/jhy-ocean/p/5560857.html MySql时间戳涉及的函数 date_format(date, format) 函数，MySQL日期格式化函数date_format() unix_timestamp() 函数 str_to_date(str, format) 函数 from_unixtime(unix_timestamp, format) 函数，MySQL时间戳格式化函数from_unixtime 时间转字符串

select date_format(now(), '%Y-%m-%d');

#结果：2016-01-05

时间转时间戳

select unix_timestamp(now());

#结果：1452001082

字符串转时间

select str_to_date('2016-01-02', '%Y-%m-%d %H');

#结果：2016-01-02 00:00:00

字符串转时间戳

select unix_timestamp('2016-01-02');

#结果：1451664000

时间戳转时间

select from_unixtime(1451997924);

#结果：2016-01-05 20:45:24

时间戳转字符串

select from_unixtime(1451997924,'%Y-%d');

结果：2016-01-05 20:45:24

附表 MySQL日期格式化（format）取值范围。值含义秒 %S、%s 两位数字形式的秒（ 00,01, …, 59）分 %I、%i 两位数字形式的分（ 00,01, …, 59）小时 %H 24小时制，两位数形式小时（00,01, …,23） %h 12小时制，两位数形式小时（00,01, …,12） %k 24小时制，数形式小时（0,1, …,23） %l 12小时制，数形式小时（0,1, …,12） %T 24小时制，时间形式（HH:mm:ss） %r 12小时制，时间形式（hh:mm:ss AM 或 PM） %p AM上午或PM下午周 %W 一周中每一天的名称（Sunday,Monday, …,Saturday） %a 一周中每一天名称的缩写（Sun,Mon, …,Sat） %w 以数字形式标识周（0=Sunday,1=Monday, …,6=Saturday） %U 数字表示周数，星期天为周中第一天 %u 数字表示周数，星期一为周中第一天天 %d 两位数字表示月中天数（01,02, …,31） %e 数字表示月中天数（1,2, …,31） %D 英文后缀表示月中天数（1st,2nd,3rd […]

龙生 04 Jun 2021

View Details

装饰器模式

装饰器模式（Decorator Pattern）允许向一个现有的对象添加新的功能，同时又不改变其结构。这种类型的设计模式属于结构型模式，它是作为现有的类的一个包装。这种模式创建了一个装饰类，用来包装原有的类，并在保持类方法签名完整性的前提下，提供了额外的功能。我们通过下面的实例来演示装饰器模式的用法。其中，我们将把一个形状装饰上不同的颜色，同时又不改变形状类。介绍意图：动态地给一个对象添加一些额外的职责。就增加功能来说，装饰器模式相比生成子类更为灵活。主要解决：一般的，我们为了扩展一个类经常使用继承方式实现，由于继承为类引入静态特征，并且随着扩展功能的增多，子类会很膨胀。何时使用：在不想增加很多子类的情况下扩展类。如何解决：将具体功能职责划分，同时继承装饰者模式。关键代码： 1、Component 类充当抽象角色，不应该具体实现。 2、修饰类引用和继承 Component 类，具体扩展类重写父类方法。应用实例： 1、孙悟空有 72 变，当他变成"庙宇"后，他的根本还是一只猴子，但是他又有了庙宇的功能。 2、不论一幅画有没有画框都可以挂在墙上，但是通常都是有画框的，并且实际上是画框被挂在墙上。在挂在墙上之前，画可以被蒙上玻璃，装到框子里；这时画、玻璃和画框形成了一个物体。优点：装饰类和被装饰类可以独立发展，不会相互耦合，装饰模式是继承的一个替代模式，装饰模式可以动态扩展一个实现类的功能。缺点：多层装饰比较复杂。使用场景： 1、扩展一个类的功能。 2、动态增加功能，动态撤销。注意事项：可代替继承。实现我们将创建一个 Shape 接口和实现了 Shape 接口的实体类。然后我们创建一个实现了 Shape 接口的抽象装饰类 ShapeDecorator，并把 Shape 对象作为它的实例变量。 RedShapeDecorator 是实现了 ShapeDecorator 的实体类。 DecoratorPatternDemo 类使用 RedShapeDecorator 来装饰 Shape 对象。步骤 1 创建一个接口： Shape.java

public interface Shape {

void draw();

}

步骤 2 创建实现接口的实体类。 Rectangle.java

public class Rectangle implements Shape {

@Override

public void draw() {

System.out.println("Shape: Rectangle");

}

Circle.java

public class Circle implements Shape {

@Override

public void draw() {

System.out.println("Shape: Circle");

}

步骤 3 创建实现了 Shape 接口的抽象装饰类。 ShapeDecorator.java

public abstract class ShapeDecorator implements Shape {

protected Shape decoratedShape;public ShapeDecorator(Shape decoratedShape){

this.decoratedShape = decoratedShape;

}

public void draw(){

decoratedShape.draw();

}

步骤 4 创建扩展了 ShapeDecorator 类的实体装饰类。 RedShapeDecorator.java

public class RedShapeDecorator extends ShapeDecorator {

public RedShapeDecorator(Shape decoratedShape) {

super(decoratedShape);

}

@Override

public void draw() {

decoratedShape.draw();

setRedBorder(decoratedShape);

}

private void setRedBorder(Shape decoratedShape){

System.out.println("Border Color: Red");

}

步骤 5 使用 RedShapeDecorator 来装饰 Shape 对象。 […]

龙生 27 May 2021

View Details

Guava 快速入门（一）

Guava工程包含了若干被Google的 Java项目广泛依赖的核心库，例如：集合 [collections] 、缓存 [caching] 、原生类型支持 [primitives support] 、并发库 [concurrency libraries] 、通用注解 [common annotations] 、字符串处理 [string processing] 、I/O 等等。 Guava 是Java的工具集，提供了一些常用的便利的操作工具类，减少因为空指针、异步操作等引起的问题BUG，提高开发效率。本文主要介绍了Guava常用的工具方法，快速入门Guava。 1、基本工具（Base utils） 1. Optional null 值出现在代码中，有如下缺点：语义模糊，引起歧义。例如，Map.get(key)返回Null时，可能表示map中的值是null，亦或map中没有key对应的值。在应用层面可能造成混乱，出现令人意外的错误。为了尽量避免程序中的null值，guava提供了Optional对数据进行封装。如果值为空则立即抛出异常，并且提供了Absent和Present两个子类分别表示值缺失和值存在的情形，来增强null的语义。常用方法如下： isPresent()：如果Optional包含非null的引用（引用存在），返回true get() ：如果Optional为NULL将触发异常

public static void test(){

Optional<Integer> possible = Optional.fromNullable(5); //创建允许null值的Optional

if(possible.isPresent()){//包含的引用非null的（引用存在），返回true

System.out.println(possible.get());

}else{

System.out.println("possible is null");

}

or(defaultvalue) ：包含的引用缺失(null)，返回默认的值，否则返回本身 orNull()：包含的引用缺失，返回null asSet()：如果引用存在，返回只有单一元素的集合；若为NULl返回空集合 2. 先决条件 Preconditions Preconditions 提供了判断条件是否合法的静态方法，如果不符合要求会抛出异常。类似断言。方法声明（不包括额外参数）描述检查失败时抛出的异常 checkArgument(boolean) 检查boolean是否为true，用来检查传递给方法的参数 IllegalArgumentException checkNotNull(T) 检查value是否为null，该方法直接返回value，因此可以内嵌使用checkNotNull NullPointerException checkState(boolean) 用来检查对象的某些状态。 IllegalStateException checkElementIndex(int index, int size) 检查index作为索引值对某个列表、字符串或数组是否有效。index>=0 && index<size IndexOutOfBoundsException checkPositionIndex(int index, int size) 检查index作为位置值对某个列表、字符串或数组是否有效。index>=0 && index<=size IndexOutOfBoundsException checkPositionIndexes(int start, int end, int size) 检查[start, end]表示的位置范围对某个列表、字符串或数组是否有效 IndexOutOfBoundsException 每个判断方法都有三个多态方法：没有额外参数：抛出的异常中没有错误消息；有一个Object对象作为额外参数：抛出的异常使用Object.toString() 作为错误消息；有一个String对象作为额外参数，并且有一组任意数量的附加Object对象：这个变种处理异常消息的方式有点类似printf，但考虑GWT的兼容性和效率，只支持%s指示符。例如：

checkArgument(i >= 0);

checkArgument(i >= 0, "Argument was expected nonnegative");

checkArgument(i < j, "Expected i < j, but %s > %s", i, j);

3. […]

龙生 26 May 2021

View Details

« Previous 1 … 92 93 94 … 418 Next »