Mysql Openstack Stored Procedures - История изменений

Sirmax в 11:35, 21 сентября 2016

2016-09-21T11:35:33Z

← Предыдущая		Версия 11:35, 21 сентября 2016
Строка 8:		Строка 8:
	Идея на самом деле сомнительная потому что на время исполнения триггера таблица блокируется но как POC сойдет		Идея на самом деле сомнительная потому что на время исполнения триггера таблица блокируется но как POC сойдет

		+	* http://www.mooreds.com/wordpress/archives/1497 Пример
		+
		+
		+	==INSERT==
	<PRE>		<PRE>
	DELIMITER \|		DELIMITER \|
Строка 21:		Строка 25:
	END \|		END \|
	DELIMITER ;		DELIMITER ;
−
−
	</PRE>		</PRE>


		+	==BEFORE UPDATE==
−
	<PRE>		<PRE>
−
	DELIMITER \|		DELIMITER \|
	DROP TRIGGER IF EXISTS nova_instances_before_update;		DROP TRIGGER IF EXISTS nova_instances_before_update;
Строка 41:		Строка 42:
	END \|		END \|
	DELIMITER ;		DELIMITER ;
−
	</PRE>		</PRE>

		+	==AFTER UPDATE==
	<PRE>		<PRE>
	DELIMITER \|		DELIMITER \|
Строка 57:		Строка 58:
	END \|		END \|
	DELIMITER ;		DELIMITER ;
		⚫	</PRE>


		⚫	==Log==
⚫	</PRE>
		+	Табличка для записи в лог того что отправляется (debug)

	<PRE>		<PRE>
−
	DROP TABLE IF EXISTS httplog;		DROP TABLE IF EXISTS httplog;
	CREATE TABLE `httplog`		CREATE TABLE `httplog`
Строка 73:		Строка 75:
	PRIMARY KEY (`seq`)		PRIMARY KEY (`seq`)
	);		);
−

	</PRE>		</PRE>

		+	==Отправка по HTTP==
⚫	==~~123~~==
−
−
	<PRE>		<PRE>

Sirmax: /* Хранимые процедуры и отсылка оповещений об изменениях на HTTP */

2016-09-21T11:33:00Z

Хранимые процедуры и отсылка оповещений об изменениях на HTTP

← Предыдущая		Версия 11:33, 21 сентября 2016
Строка 3:		Строка 3:
	=Хранимые процедуры и отсылка оповещений об изменениях на HTTP=		=Хранимые процедуры и отсылка оповещений об изменениях на HTTP=

−	В MySQL есть такая возможность - использовать внешние пользовательские процедуры написанные на языке C <BR>	+	В MySQL есть такая возможность - использовать внешние пользовательские процедуры написанные на языке C <BR>
	Это дает возможность сделать триггер который при апдейте таблицы будет форматировать JSON и отправлять на удаленный сервер (или сервера)		Это дает возможность сделать триггер который при апдейте таблицы будет форматировать JSON и отправлять на удаленный сервер (или сервера)
	<BR>		<BR>

Sirmax в 11:32, 21 сентября 2016

2016-09-21T11:32:35Z

@@ Строка 1: / Строка 1: @@
 <PRE>
@@ Строка 69: / Строка 28: @@
 <PRE>
 DELIMITER |
@@ Строка 87: / Строка 45: @@
 <PRE>
 DELIMITER |
 DROP TRIGGER IF EXISTS nova_instances_after_update;
@@ Строка 153: / Строка 109: @@
 <PRE>
 DROP PROCEDURE IF EXISTS upload2;
 DELIMITER |
@@ Строка 184: / Строка 137: @@
 END |
 DELIMITER ;
 </PRE>
 =Ссылки=
 * https://habrahabr.ru/post/37693/ - триггера
-http://www.mooreds.com/wordpress/archives/1497 Пример
+* http://www.mooreds.com/wordpress/archives/1497 Пример
-https://github.com/y-ken/mysql-udf-http
+* https://github.com/y-ken/mysql-udf-http
-http://dev.mysql.com/doc/refman/5.7/en/adding-udf.html
+* http://dev.mysql.com/doc/refman/5.7/en/adding-udf.html

Sirmax: Sirmax переименовал страницу Test1 в Mysql Openstack Stored Procedures

2016-09-21T11:27:59Z

Sirmax переименовал страницу Test1 в Mysql Openstack Stored Procedures

← Предыдущая

Версия 11:27, 21 сентября 2016

Sirmax в 07:29, 2 сентября 2016

2016-09-02T07:29:15Z

← Предыдущая		Версия 07:29, 2 сентября 2016
Строка 57:		Строка 57:
	SET @tt_json = (SELECT json_object(created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted ) FROM instances WHERE uuid = NEW.uuid LIMIT 1);		SET @tt_json = (SELECT json_object(created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted ) FROM instances WHERE uuid = NEW.uuid LIMIT 1);

−	~~SET~~ ~~@http_host=~~http://~~127~~.0.0.1:~~8081~~/'	+	CALL send_http_data('http://172.16.169.34:8080/', @tt_json);
		⚫	CALL send_http_data('http://127.0.0.1:8081/', @tt_json);
−	SET @tt_resu = (SELECT http_post(CONCAT(@http_host, NEW.id), @tt_json));
−	INSERT INTO httplog(http_host, request,response) values( @tt_json, @tt_resu);
−
⚫	~~SET~~ ~~@http_host=~~http://127.0.0.1:8081/'
−	SET @tt_resu = (SELECT http_post(CONCAT(@http_host, NEW.id), @tt_json));
−	INSERT INTO httplog(http_host, request,response) values( @tt_json, @tt_resu);

	END \|		END \|
Строка 83:		Строка 78:
	SET @tt_json = (SELECT json_object(created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted ) FROM instances WHERE uuid = OLD.uuid LIMIT 1);		SET @tt_json = (SELECT json_object(created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted ) FROM instances WHERE uuid = OLD.uuid LIMIT 1);

−	// ~~SET~~ ~~@tt_resu = (SELECT http_post(CONCAT~~('http://~~127~~.0.0.1:~~8081~~/'~~, OLD.id)~~, @tt_json));	+	CALL send_http_data('http://172.16.169.34:8080/', @tt_json);
−	// ~~SET~~ ~~@tt_resu = (SELECT http_post(CONCAT~~('http://~~172~~.16.~~169~~.34:~~8080~~/'~~, OLD.id)~~, @tt_json));	+	CALL send_http_data('http://127.0.0.1:8081/', @tt_json);
−	// INSERT INTO httplog(request,response) values( @tt_json, @tt_resu);
−
−
−	SET @http_host=http://127.0.0.1:8081/'
−	SET @tt_resu = (SELECT http_post(CONCAT(@http_host, NEW.id), @tt_json));
−	INSERT INTO httplog(http_host, request,response) values( @tt_json, @tt_resu);
−
−	SET @http_host=http://127.0.0.1:8081/'
−	SET @tt_resu = (SELECT http_post(CONCAT(@http_host, NEW.id), @tt_json));
−	INSERT INTO httplog(http_host, request,response) values( @tt_json, @tt_resu);

	END \|		END \|
Строка 111:		Строка 96:
	SET @tt_json = (SELECT json_object(created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted ) FROM instances WHERE uuid= OLD.uuid LIMIT 1);		SET @tt_json = (SELECT json_object(created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted ) FROM instances WHERE uuid= OLD.uuid LIMIT 1);

−	// ~~SET~~ ~~@tt_resu = (SELECT http_post(CONCAT~~('http://~~127~~.0.0.1:~~8081~~/'~~, OLD.uuid)~~, @tt_json));	+	CALL send_http_data('http://172.16.169.34:8080/', @tt_json);
−	// ~~SET~~ ~~@tt_resu = (SELECT http_post(CONCAT~~('http://~~172~~.16.~~169~~.34:~~8080~~/'~~, OLD.id)~~, @tt_json));	+	CALL send_http_data('http://127.0.0.1:8081/', @tt_json);
−	// INSERT INTO httplog(request,response) values( @tt_json, @tt_resu);
−
−	SET @http_host=http://127.0.0.1:8081/'
−	SET @tt_resu = (SELECT http_post(CONCAT(@http_host, NEW.id), @tt_json));
−	INSERT INTO httplog(http_host, request,response) values( @tt_json, @tt_resu);
−
−	SET @http_host=http://127.0.0.1:8081/'
−	SET @tt_resu = (SELECT http_post(CONCAT(@http_host, NEW.id), @tt_json));
−	INSERT INTO httplog(http_host, request,response) values( @tt_json, @tt_resu);

	END \|		END \|
Строка 134:		Строка 110:
	CREATE TABLE `httplog`		CREATE TABLE `httplog`
	(		(
−	`request` varchar(~~512~~) DEFAULT NULL,	+	`request` varchar(4096) DEFAULT NULL,
−	`response` varchar(~~512~~) DEFAULT NULL,	+	`response` varchar(4096) DEFAULT NULL,
	`seq` int(10) unsigned NOT NULL AUTO_INCREMENT,		`seq` int(10) unsigned NOT NULL AUTO_INCREMENT,
	`local_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,		`local_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
Строка 154:		Строка 130:
	DELIMITER \|		DELIMITER \|
	CREATE PROCEDURE send_http_data(		CREATE PROCEDURE send_http_data(
−	IN http_host ~~MEDIUMTEXT~~,	+	IN http_host varchar(512),
−	IN http_data ~~MEDIUMTEXT~~	+	IN http_data varchar(4096)
	) BEGIN		) BEGIN

Строка 215:		Строка 191:
	=Ссылки=		=Ссылки=
	* https://habrahabr.ru/post/37693/ - триггера		* https://habrahabr.ru/post/37693/ - триггера
		+	http://www.mooreds.com/wordpress/archives/1497 Пример
		+	https://github.com/y-ken/mysql-udf-http
		+	http://dev.mysql.com/doc/refman/5.7/en/adding-udf.html

Sirmax: /* 123 */

2016-09-01T14:48:44Z

123

← Предыдущая		Версия 14:48, 1 сентября 2016
Строка 180:		Строка 180:


−	DROP PROCEDURE IF EXISTS ~~upload~~;	+	DROP PROCEDURE IF EXISTS upload2;
	DELIMITER \|		DELIMITER \|

−	CREATE PROCEDURE ~~upload~~() BEGIN	+	CREATE PROCEDURE upload2() BEGIN
	DECLARE done BOOLEAN DEFAULT FALSE;		DECLARE done BOOLEAN DEFAULT FALSE;
−	DECLARE ~~_data~~ TEXT;	+	DECLARE json_data TEXT;
		+	DECLARE _uuid TEXT;
⚫	~~DECLARE~~ ~~cur CURSOR FOR~~ SELECT json_object(created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted) FROM instances;
		+	DECLARE cur CURSOR FOR SELECT uuid from instances;
	DECLARE CONTINUE HANDLER FOR NOT FOUND SET done := TRUE;		DECLARE CONTINUE HANDLER FOR NOT FOUND SET done := TRUE;

Строка 192:		Строка 193:

	testLoop: LOOP		testLoop: LOOP
−	FETCH cur INTO ~~_data~~;	+	FETCH cur INTO _uuid;
	IF done THEN		IF done THEN
	LEAVE testLoop;		LEAVE testLoop;
	END IF;		END IF;

		⚫	SELECT json_object(created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted) FROM instances WHERE uuid=_uuid LIMIT 1 INTO json_data;

−	~~SET~~ ~~@http_host=~~'http://172.16.169.34:8080/';	+	CALL send_http_data('http://172.16.169.34:8080/', json_data);
		⚫	CALL send_http_data('http://127.0.0.1:8081/', json_data);
−	SET @tt_resu = (SELECT http_post(@http_host, _data));
−	INSERT INTO httplog(host, request,response) values(@http_host, @tt_json, @tt_resu);
−
⚫	~~SET~~ ~~@http_host=~~'http://127.0.0.1:~~8080~~/';
−	SET @tt_resu = (SELECT http_post(@http_host, _data));
−	INSERT INTO httplog(host, request,response) values(@http_host, @tt_json, @tt_resu);

	END LOOP testLoop;		END LOOP testLoop;

Sirmax в 14:33, 1 сентября 2016

2016-09-01T14:33:17Z

← Предыдущая		Версия 14:33, 1 сентября 2016
Строка 150:		Строка 150:
	<PRE>		<PRE>

−	DROP PROCEDURE IF EXISTS ~~send_http~~;	+	DROP PROCEDURE IF EXISTS send_http_data;

	DELIMITER \|		DELIMITER \|
−	CREATE PROCEDURE ~~send_http~~( ~~IN http_host: MEDIUMTEXT, IN _data: MEDIUMTEXT ) BEGIN~~	+	CREATE PROCEDURE send_http_data(
		+	IN http_host MEDIUMTEXT,
		+	IN http_data MEDIUMTEXT
		+	) BEGIN
		+
		+
		+
		+
		+	SET @tt_resu = (SELECT http_post(http_host, http_data));
		+	INSERT INTO httplog(host, request,response) values(http_host, http_data, @tt_resu);

	END \|		END \|

Sirmax: /* 123 */

2016-09-01T14:25:29Z

123

← Предыдущая		Версия 14:25, 1 сентября 2016
Строка 146:		Строка 146:

	==123==		==123==
		+
		+
		+	<PRE>
		+
		+	DROP PROCEDURE IF EXISTS send_http;
		+
		+	DELIMITER \|
		+	CREATE PROCEDURE send_http( IN http_host: MEDIUMTEXT, IN _data: MEDIUMTEXT ) BEGIN
		+
		+	END \|
		+	DELIMITER ;
		+
		+
		+
		+
		+	SET @tt_resu = (SELECT http_post(http_host, _data));
		+	INSERT INTO httplog(host, request,response) values(http_host, _data, @tt_resu);
		+	</PRE>
		+
		+
		+
	<PRE>		<PRE>

Sirmax в 14:10, 1 сентября 2016

2016-09-01T14:10:56Z

← Предыдущая		Версия 14:10, 1 сентября 2016
Строка 168:		Строка 168:


−	SET @http_host='http://172.16.169.34:~~8081~~/';	+	SET @http_host='http://172.16.169.34:8080/';
	SET @tt_resu = (SELECT http_post(@http_host, _data));		SET @tt_resu = (SELECT http_post(@http_host, _data));
	INSERT INTO httplog(host, request,response) values(@http_host, @tt_json, @tt_resu);		INSERT INTO httplog(host, request,response) values(@http_host, @tt_json, @tt_resu);

Sirmax: /* 123 */

2016-09-01T14:10:02Z

123

← Предыдущая		Версия 14:10, 1 сентября 2016
Строка 168:		Строка 168:


−	SET @http_host='http://~~127~~.0.0.1:8081/';	+	SET @http_host='http://172.16.169.34:8081/';
	SET @tt_resu = (SELECT http_post(@http_host, _data));		SET @tt_resu = (SELECT http_post(@http_host, _data));
	INSERT INTO httplog(host, request,response) values(@http_host, @tt_json, @tt_resu);		INSERT INTO httplog(host, request,response) values(@http_host, @tt_json, @tt_resu);