Le [MySQL Casual Advent Calendar 2017] d'hier (https://qiita.com/advent-calendar/2017/mysql-casual) était celui de @ soudai1025 [Pourquoi ne pas lire SHOW ENGINE INNODB STATUS](http: / /soudai.hatenablog.com/entry/2017/12/20/030013).

** Benching en modifiant les propriétés avec MySQL Connector / J Part 1: Batch Edition ([MySQL Casual Advent Calendar 2017](https: // qiita) .com / advent-calendar / 2017 / mysql-casual) Jour 10) **
** Benching en modifiant les propriétés avec MySQL Connector / J Partie 2: Arrêtez les conversations inutiles (MySQL Casual Advent Calendar 2017 //qiita.com/advent-calendar/2017/mysql-casual) Jour 17) **

C'est une continuation de.

Cette fois, nous vérifierons si les performances peuvent être améliorées en activant la fonction de cache de l'instruction préparée.

1. Propriétés à vérifier

5.1 Driver/Datasource Class Names, URL Syntax and Configuration Properties for Connector/J（MySQL Connector/J 5.1 Developer Guide）

cachePrepStmts Utiliser / ne pas utiliser le cache des instructions préparées (** false **)
prepStmtCacheSize Nombre d'instructions préparées à mettre en cache (** 25 **)
prepStmtCacheSqlLimit Nombre maximum de caractères dans les instructions préparées à mettre en cache (** 256 **)
** Bold ** est la valeur par défaut

Pour examiner la modification des performances lors de la modification de la valeur par défaut

Semblable à Partie 2, les articles suivants seront utiles.
** Celui qui semble fonctionner avec les paramètres de mysql Connector / J M.) **

De plus, comme indiqué dans l'article ci-dessus, la valeur recommandée de HikariCP (regroupement de connexions à haut débit) est indiquée ici.

MySQL Configuration（GitHub／HikariCP Wiki）

Cette fois, j'ai modifié le code utilisé dans Part 1 (un nouveau tableau est préparé).

8 fils
100 000 lignes par fil
COMMIT en unités de 10000 lignes
Émettre 70 types de déclarations préparées

Sous la forme de, les trois modèles suivants sont comparés et vérifiés.

Uniquement les propriétés utilisées dans Partie 2 ** (cache désactivé) **
Propriétés utilisées dans Partie 2 + ** Cache valide + Cache limite supérieure 50 + Nombre maximum de caractères 2048 **
Propriétés utilisées dans Partie 2 + ** Cache valide + Cache limite supérieure 100 + Nombre maximum de caractères 2048 **

2. Résultat de la vérification

Le résultat de la vérification à chaque heure requise est affiché.

Modèle de vérification	Temps requis(ms)
Seules les propriétés utilisées dans la partie 2	38,057
Propriétés utilisées dans la partie 2 +`cachePrepStmts=true&prepStmtCacheSize=50&prepStmtCacheSqlLimit=2048`	39,907
Propriétés utilisées dans la partie 2 +`cachePrepStmts=true&prepStmtCacheSize=100&prepStmtCacheSqlLimit=2048`	30,027

** Si la limite supérieure du cache <type d'instruction préparée émis (nombre), elle se trouve presque dans la plage d'erreur **
** Plus rapide si la limite de cache ≥ émet le type d'instruction préparée (nombre) **

J'ai découvert.

Bien que cela ne soit pas montré en conséquence, nous avons en fait essayé et confirmé même la limite supérieure du cache (prepStmtCacheSize) de 69 et 70.

3. Résumé

Pour être honnête, j'ai été surpris que les déclarations préparées basées sur le client aient un effet de mise en cache. Je voudrais vérifier le code source une fois et voir quel type de traitement il effectue.

Cette fois, c'est "** Casual ** Advent Calendar" donc je n'irai pas aussi loin.

Cependant, si le nombre d'instructions préparées utilisées quotidiennement dépasse ne serait-ce qu'une seule limite de cache, l'effet peut devenir nul (dans certains cas négatif) (l'algorithme de cache n'est pas très bon). (Peut-être), je pense que c'est assez difficile à utiliser.

Il y a aussi l'aspect que le code de vérification n'est pas bon. Chaque instruction préparée est répétée pour chaque thread, une ligne pour chaque type, et elle entre et sort toujours du cache dans presque le même ordre pendant un tour.

À tout le moins, ** HikariCP recommande 250, alors gardons-le à 250 **, car cela peut causer des problèmes inattendus à mesure que l'application se développe, il est donc préférable de l'éviter.

Tomorrow's MySQL Casual Advent Calendar 2017 essaiera @ huato's docker-compose pour créer facilement un environnement de test pour la réplication de groupe. .

4. Code de vérification, etc.

La base est celle utilisée dans la Partie 1. Les éléments suivants sont ajoutés / modifiés.

`DbInsert.Java (code ajouté à partir de la ligne 66)`



	private static final int		PSMT_ALL_COLUMN	= 70;
	private static final int		PSMT_STORE_COLUMN	= 10;
	private static final String 	PSMT_MEMO			= "1234567890";

	public void psmtInsert(int totalline, int commitline, String option) {

		try (
			Connection 			con		= new DbConnection().getConnectionForTest(JDBC_URL + option);
		) {
			con.setAutoCommit(false);

			for (int i = 0; i < totalline; i++) {
				StringBuilder	sb_pfx	= new StringBuilder("INSERT INTO psmt_test.psmt_test (");
				StringBuilder	sb_sfx	= new StringBuilder(" VALUES (");
				for (int j = 1; j <= PSMT_STORE_COLUMN; j++) {
					sb_pfx.append("memo" + (Integer.toString((i % PSMT_ALL_COLUMN) + j) + ((j == PSMT_STORE_COLUMN) ? ")" : ", ")));
					sb_sfx.append("?" + ((j == PSMT_STORE_COLUMN) ? ")" : ", "));
				}
				try (
					PreparedStatement	psmt	= con.prepareStatement(sb_pfx.toString() + sb_sfx.toString());
				) {
					for (int j = 1; j <= PSMT_STORE_COLUMN; j++) {
						psmt.setString(j, PSMT_MEMO);
					}
					psmt.execute();
					if (((i + 1) % commitline == 0) || ((i + 1) == totalline)) {
						con.commit();
					}
				} catch (SQLException e) {
					throw e;				}
			}
		} catch (ClassNotFoundException e) {
			System.out.println("[Error] Driver not found.");
			e.printStackTrace();
		} catch (SQLException e) {
			System.out.println("[Error] Invalid DB access.");
			e.printStackTrace();
		}
	}

`PsmtInsert.java (nouvel ajout)`


package site.hmatsu47.conjtest;

public class PsmtInsert extends Thread {

	private int 	totalline	= 0;
	private int 	commitline	= 0;
	private String option;
	private String title;

	public PsmtInsert(int totalline, int commitline, String option, String title) {
		this.totalline	= totalline;
		this.commitline	= commitline;
		this.option		= option;
		this.title		= title;
	}

	public void run() {
		long	starttime	= System.nanoTime();

		new DbInsert().psmtInsert(totalline, commitline, option);

		long	endtime	= System.nanoTime();

		System.out.println("[Psmt]   " + title + " : " + String.valueOf((endtime - starttime) / (1000 * 1000)) + " msec.");
	}
}

`Main.java (modifier)`


package site.hmatsu47.conjtest;

public class Main {

	private static final int		DEFAULT_SIMPLE_THREAD	= 0;
	private static final int		DEFAULT_BATCH_THREAD		= 1;
	private static final int		DEFAULT_TOTAL_LINE		= 1000000;
	private static final int		DEFAULT_BATCH_LINE		= 100;
	private static final int		DEFAULT_COMMITL_LINE		= 1000;
	private static final String	DEFAULT_JDBC_OPTION		= "";
	private static final int		DEFAULT_PSMT_THREAD		= 0;

	public static void main(String args[]) {
		try {
			final int		simplethread	= (args.length < 1 ? DEFAULT_SIMPLE_THREAD : Integer.valueOf(args[0]).intValue());
			final int		batchthread	= (args.length < 2 ? DEFAULT_BATCH_THREAD : Integer.valueOf(args[1]).intValue());
			final int		totalline		= (args.length < 3 ? DEFAULT_TOTAL_LINE : Integer.valueOf(args[2]).intValue());
			final int		batchline		= (args.length < 4 ? DEFAULT_BATCH_LINE : Integer.valueOf(args[3]).intValue());
			final int		commitline		= (args.length < 5 ? DEFAULT_COMMITL_LINE : Integer.valueOf(args[4]).intValue());
			final String	option			= (args.length < 6 ? DEFAULT_JDBC_OPTION : args[5]);
			final int		psmtthread		= (args.length < 7 ? DEFAULT_PSMT_THREAD : Integer.valueOf(args[6]).intValue());

			for (int i = 1; i <= simplethread; i++) {
				SimpleInsert si = new SimpleInsert(totalline, commitline, option, String.valueOf(i));
				si.start();
				Thread.sleep(1000);
			}

			for (int i = 1; i <= batchthread; i++) {
				BatchInsert bi = new BatchInsert(totalline, batchline, commitline, option, String.valueOf(i));
				bi.start();
				Thread.sleep(1000);
			}

			for (int i = 1; i <= psmtthread; i++) {
				PsmtInsert pi = new PsmtInsert(totalline, commitline, option, String.valueOf(i));
				pi.start();
				Thread.sleep(1000);
			}
		}
		catch (Exception e) {
			System.out.println("[Error]");
			e.printStackTrace();
		}
	}
}

`Définition supplémentaire de DB / table`


CREATE DATABASE psmt_test;
CREATE TABLE psmt_test.psmt_test
  (id INT UNSIGNED PRIMARY KEY AUTO_INCREMENT,
   memo1 VARCHAR(10),
   memo2 VARCHAR(10),
   memo3 VARCHAR(10),
   memo4 VARCHAR(10),
   memo5 VARCHAR(10),
   memo6 VARCHAR(10),
   memo7 VARCHAR(10),
   memo8 VARCHAR(10),
   memo9 VARCHAR(10),
   memo10 VARCHAR(10),
   memo11 VARCHAR(10),
   memo12 VARCHAR(10),
   memo13 VARCHAR(10),
   memo14 VARCHAR(10),
   memo15 VARCHAR(10),
   memo16 VARCHAR(10),
   memo17 VARCHAR(10),
   memo18 VARCHAR(10),
   memo19 VARCHAR(10),
   memo20 VARCHAR(10),
   memo21 VARCHAR(10),
   memo22 VARCHAR(10),
   memo23 VARCHAR(10),
   memo24 VARCHAR(10),
   memo25 VARCHAR(10),
   memo26 VARCHAR(10),
   memo27 VARCHAR(10),
   memo28 VARCHAR(10),
   memo29 VARCHAR(10),
   memo30 VARCHAR(10),
   memo31 VARCHAR(10),
   memo32 VARCHAR(10),
   memo33 VARCHAR(10),
   memo34 VARCHAR(10),
   memo35 VARCHAR(10),
   memo36 VARCHAR(10),
   memo37 VARCHAR(10),
   memo38 VARCHAR(10),
   memo39 VARCHAR(10),
   memo40 VARCHAR(10),
   memo41 VARCHAR(10),
   memo42 VARCHAR(10),
   memo43 VARCHAR(10),
   memo44 VARCHAR(10),
   memo45 VARCHAR(10),
   memo46 VARCHAR(10),
   memo47 VARCHAR(10),
   memo48 VARCHAR(10),
   memo49 VARCHAR(10),
   memo50 VARCHAR(10),
   memo51 VARCHAR(10),
   memo52 VARCHAR(10),
   memo53 VARCHAR(10),
   memo54 VARCHAR(10),
   memo55 VARCHAR(10),
   memo56 VARCHAR(10),
   memo57 VARCHAR(10),
   memo58 VARCHAR(10),
   memo59 VARCHAR(10),
   memo60 VARCHAR(10),
   memo61 VARCHAR(10),
   memo62 VARCHAR(10),
   memo63 VARCHAR(10),
   memo64 VARCHAR(10),
   memo65 VARCHAR(10),
   memo66 VARCHAR(10),
   memo67 VARCHAR(10),
   memo68 VARCHAR(10),
   memo69 VARCHAR(10),
   memo70 VARCHAR(10),
   memo71 VARCHAR(10),
   memo72 VARCHAR(10),
   memo73 VARCHAR(10),
   memo74 VARCHAR(10),
   memo75 VARCHAR(10),
   memo76 VARCHAR(10),
   memo77 VARCHAR(10),
   memo78 VARCHAR(10),
   memo79 VARCHAR(10),
   memo80 VARCHAR(10)
  );

[JAVA] Benching en modifiant les propriétés avec MySQL Connector / J Partie 3: Cache d'instructions préparé

1. Propriétés à vérifier

2. Résultat de la vérification

3. Résumé

4. Code de vérification, etc.

DbInsert.Java (code ajouté à partir de la ligne 66)

PsmtInsert.java (nouvel ajout)

Main.java (modifier)

Définition supplémentaire de DB / table

`DbInsert.Java (code ajouté à partir de la ligne 66)`

`PsmtInsert.java (nouvel ajout)`

`Main.java (modifier)`

`Définition supplémentaire de DB / table`