diff --git a/test/e2e/testing-manifests/statefulset/mysql-upgrade/configmap.yaml b/test/e2e/testing-manifests/statefulset/mysql-upgrade/configmap.yaml new file mode 100644 index 00000000000..c1f95a6e9a7 --- /dev/null +++ b/test/e2e/testing-manifests/statefulset/mysql-upgrade/configmap.yaml @@ -0,0 +1,13 @@ +apiVersion: v1 +kind: ConfigMap +metadata: + name: mysql + labels: + app: mysql +data: + master.cnf: | + [mysqld] + log-bin + slave.cnf: | + [mysqld] + super-read-only diff --git a/test/e2e/testing-manifests/statefulset/mysql-upgrade/service.yaml b/test/e2e/testing-manifests/statefulset/mysql-upgrade/service.yaml new file mode 100644 index 00000000000..3ab2f80bbb3 --- /dev/null +++ b/test/e2e/testing-manifests/statefulset/mysql-upgrade/service.yaml @@ -0,0 +1,27 @@ +apiVersion: v1 +kind: Service +metadata: + name: mysql + labels: + app: mysql +spec: + ports: + - name: mysql + port: 3306 + clusterIP: None + selector: + app: mysql +--- +apiVersion: v1 +kind: Service +metadata: + name: mysql-read + labels: + app: mysql +spec: + ports: + - name: mysql + port: 3306 + selector: + app: mysql + type: LoadBalancer diff --git a/test/e2e/testing-manifests/statefulset/mysql-upgrade/statefulset.yaml b/test/e2e/testing-manifests/statefulset/mysql-upgrade/statefulset.yaml new file mode 100644 index 00000000000..4e319c61af5 --- /dev/null +++ b/test/e2e/testing-manifests/statefulset/mysql-upgrade/statefulset.yaml @@ -0,0 +1,159 @@ +apiVersion: apps/v1beta1 +kind: StatefulSet +metadata: + name: mysql +spec: + serviceName: mysql + replicas: 3 + template: + metadata: + labels: + app: mysql + annotations: + pod.beta.kubernetes.io/init-containers: '[ + { + "name": "init-mysql", + "image": "mysql:5.7", + "command": ["bash", "-c", " + set -ex\n + [[ `hostname` =~ -([0-9]+)$ ]] || exit 1\n + ordinal=${BASH_REMATCH[1]}\n + echo [mysqld] > /mnt/conf.d/server-id.cnf\n + echo server-id=$((100 + $ordinal)) >> /mnt/conf.d/server-id.cnf\n + if [[ $ordinal -eq 0 ]]; then\n + cp /mnt/config-map/master.cnf /mnt/conf.d/\n + else\n + cp /mnt/config-map/slave.cnf /mnt/conf.d/\n + fi\n + "], + "volumeMounts": [ + {"name": "conf", "mountPath": "/mnt/conf.d"}, + {"name": "config-map", "mountPath": "/mnt/config-map"} + ] + }, + { + "name": "clone-mysql", + "image": "gcr.io/google-samples/xtrabackup:1.0", + "command": ["bash", "-c", " + set -ex\n + [[ -d /var/lib/mysql/mysql ]] && exit 0\n + [[ `hostname` =~ -([0-9]+)$ ]] || exit 1\n + ordinal=${BASH_REMATCH[1]}\n + [[ $ordinal -eq 0 ]] && exit 0\n + ncat --recv-only mysql-$(($ordinal-1)).mysql 3307 | xbstream -x -C /var/lib/mysql\n + xtrabackup --prepare --target-dir=/var/lib/mysql\n + "], + "volumeMounts": [ + {"name": "data", "mountPath": "/var/lib/mysql", "subPath": "mysql"}, + {"name": "conf", "mountPath": "/etc/mysql/conf.d"} + ] + } + ]' + spec: + containers: + - name: mysql + image: mysql:5.7.15 + env: + - name: MYSQL_ALLOW_EMPTY_PASSWORD + value: "1" + ports: + - name: mysql + containerPort: 3306 + volumeMounts: + - name: data + mountPath: /var/lib/mysql + subPath: mysql + - name: conf + mountPath: /etc/mysql/conf.d + resources: + requests: + cpu: 1 + memory: 1Gi + livenessProbe: + exec: + command: ["mysqladmin", "ping"] + initialDelaySeconds: 30 + timeoutSeconds: 5 + readinessProbe: + exec: + command: ["mysql", "-h", "127.0.0.1", "-e", "SELECT 1"] + initialDelaySeconds: 5 + timeoutSeconds: 1 + - name: xtrabackup + image: gcr.io/google-samples/xtrabackup:1.0 + ports: + - name: xtrabackup + containerPort: 3307 + command: + - bash + - "-c" + - | + set -ex + cd /var/lib/mysql + + if [[ -f xtrabackup_slave_info ]]; then + mv xtrabackup_slave_info change_master_to.sql.in + rm -f xtrabackup_binlog_info + elif [[ -f xtrabackup_binlog_info ]]; then + [[ `cat xtrabackup_binlog_info` =~ ^(.*?)[[:space:]]+(.*?)$ ]] || exit 1 + rm xtrabackup_binlog_info + echo "CHANGE MASTER TO MASTER_LOG_FILE='${BASH_REMATCH[1]}',\ + MASTER_LOG_POS=${BASH_REMATCH[2]}" > change_master_to.sql.in + fi + + if [[ -f change_master_to.sql.in ]]; then + echo "Waiting for mysqld to be ready (accepting connections)" + until mysql -h 127.0.0.1 -e "SELECT 1"; do sleep 1; done + + echo "Initializing replication from clone position" + mv change_master_to.sql.in change_master_to.sql.orig + mysql -h 127.0.0.1 <= t.successfulWrites).To(BeTrue()) +} + +// addName adds a new value to the db. +func (t *MySqlUpgradeTest) addName(name string) error { + val := map[string][]string{"name": {name}} + t.nextWrite++ + r, err := http.PostForm(fmt.Sprintf("http://%s:8080/addName", t.ip), val) + if err != nil { + return err + } + defer r.Body.Close() + if r.StatusCode != http.StatusOK { + b, err := ioutil.ReadAll(r.Body) + if err != nil { + return err + } + return fmt.Errorf(string(b)) + } + return nil +} + +// countNames checks to make sure the values in testing.users are available, and returns +// the count of them. +func (t *MySqlUpgradeTest) countNames() (int, error) { + r, err := http.Get(fmt.Sprintf("http://%s:8080/countNames", t.ip)) + if err != nil { + return 0, err + } + defer r.Body.Close() + if r.StatusCode != http.StatusOK { + b, err := ioutil.ReadAll(r.Body) + if err != nil { + return 0, err + } + return 0, fmt.Errorf(string(b)) + } + var count int + if err := json.NewDecoder(r.Body).Decode(&count); err != nil { + return 0, err + } + return count, nil +}