mirror of
https://github.com/VinylDNS/vinyldns
synced 2025-08-22 10:10:12 +00:00
Merge pull request #1400 from nspadaccino/nspadaccino/query-updates
Mysql 8.0 compatibility
This commit is contained in:
commit
6b56ebf158
@ -34,6 +34,6 @@ trait MySqlApiIntegrationSpec extends MySqlIntegrationSpec {
|
|||||||
|
|
||||||
def clearGroupRepo(): Unit =
|
def clearGroupRepo(): Unit =
|
||||||
DB.localTx { s =>
|
DB.localTx { s =>
|
||||||
s.executeUpdate("DELETE FROM groups")
|
s.executeUpdate("DELETE FROM `groups`")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -50,7 +50,7 @@ class MySqlGroupRepositoryIntegrationSpec
|
|||||||
|
|
||||||
override protected def beforeAll(): Unit = {
|
override protected def beforeAll(): Unit = {
|
||||||
DB.localTx { s =>
|
DB.localTx { s =>
|
||||||
s.executeUpdate("DELETE FROM groups")
|
s.executeUpdate("DELETE FROM `groups`")
|
||||||
}
|
}
|
||||||
|
|
||||||
for (group <- groups) {
|
for (group <- groups) {
|
||||||
@ -60,7 +60,7 @@ class MySqlGroupRepositoryIntegrationSpec
|
|||||||
|
|
||||||
override protected def afterAll(): Unit = {
|
override protected def afterAll(): Unit = {
|
||||||
DB.localTx { s =>
|
DB.localTx { s =>
|
||||||
s.executeUpdate("DELETE FROM groups")
|
s.executeUpdate("DELETE FROM `groups`")
|
||||||
}
|
}
|
||||||
super.afterAll()
|
super.afterAll()
|
||||||
}
|
}
|
||||||
|
@ -2,6 +2,6 @@ CREATE SCHEMA IF NOT EXISTS ${dbName};
|
|||||||
|
|
||||||
USE ${dbName};
|
USE ${dbName};
|
||||||
|
|
||||||
ALTER TABLE groups ADD COLUMN description VARCHAR(256) NULL;
|
ALTER TABLE `groups` ADD COLUMN description VARCHAR(256) NULL;
|
||||||
ALTER TABLE groups ADD COLUMN created_timestamp DATETIME NOT NULL;
|
ALTER TABLE `groups` ADD COLUMN created_timestamp DATETIME NOT NULL;
|
||||||
ALTER TABLE groups ADD COLUMN email VARCHAR(256) NOT NULL;
|
ALTER TABLE `groups` ADD COLUMN email VARCHAR(256) NOT NULL;
|
||||||
|
@ -5,7 +5,7 @@ USE ${dbName};
|
|||||||
/*
|
/*
|
||||||
Create table to store groups
|
Create table to store groups
|
||||||
*/
|
*/
|
||||||
CREATE TABLE groups (
|
CREATE TABLE `groups` (
|
||||||
id CHAR(36) NOT NULL,
|
id CHAR(36) NOT NULL,
|
||||||
name VARCHAR(256) NOT NULL,
|
name VARCHAR(256) NOT NULL,
|
||||||
data BLOB NOT NULL,
|
data BLOB NOT NULL,
|
||||||
|
@ -32,47 +32,47 @@ class MySqlGroupRepository extends GroupRepository with GroupProtobufConversions
|
|||||||
|
|
||||||
private final val PUT_GROUP =
|
private final val PUT_GROUP =
|
||||||
sql"""
|
sql"""
|
||||||
|REPLACE INTO groups(id, name, data, description, created_timestamp, email)
|
|REPLACE INTO `groups`(id, name, data, description, created_timestamp, email)
|
||||||
| VALUES ({id}, {name}, {data}, {description}, {createdTimestamp}, {email})
|
| VALUES ({id}, {name}, {data}, {description}, {createdTimestamp}, {email})
|
||||||
""".stripMargin
|
""".stripMargin
|
||||||
|
|
||||||
private final val DELETE_GROUP =
|
private final val DELETE_GROUP =
|
||||||
sql"""
|
sql"""
|
||||||
|DELETE FROM groups
|
|DELETE FROM `groups`
|
||||||
| WHERE id = ?
|
| WHERE id = ?
|
||||||
""".stripMargin
|
""".stripMargin
|
||||||
|
|
||||||
private final val GET_GROUP_BY_ID =
|
private final val GET_GROUP_BY_ID =
|
||||||
sql"""
|
sql"""
|
||||||
|SELECT data
|
|SELECT data
|
||||||
| FROM groups
|
| FROM `groups`
|
||||||
| WHERE id = ?
|
| WHERE id = ?
|
||||||
""".stripMargin
|
""".stripMargin
|
||||||
|
|
||||||
private final val GET_GROUP_BY_NAME =
|
private final val GET_GROUP_BY_NAME =
|
||||||
sql"""
|
sql"""
|
||||||
|SELECT data
|
|SELECT data
|
||||||
| FROM groups
|
| FROM `groups`
|
||||||
| WHERE name = ?
|
| WHERE name = ?
|
||||||
""".stripMargin
|
""".stripMargin
|
||||||
|
|
||||||
private final val GET_ALL_GROUPS =
|
private final val GET_ALL_GROUPS =
|
||||||
sql"""
|
sql"""
|
||||||
|SELECT data
|
|SELECT data
|
||||||
| FROM groups
|
| FROM `groups`
|
||||||
""".stripMargin
|
""".stripMargin
|
||||||
|
|
||||||
private val BASE_GET_GROUPS_BY_IDS =
|
private val BASE_GET_GROUPS_BY_IDS =
|
||||||
"""
|
"""
|
||||||
|SELECT data
|
|SELECT data
|
||||||
| FROM groups
|
| FROM `groups`
|
||||||
| WHERE id
|
| WHERE id
|
||||||
""".stripMargin
|
""".stripMargin
|
||||||
|
|
||||||
private val BASE_GET_GROUPS_BY_NAMES =
|
private val BASE_GET_GROUPS_BY_NAMES =
|
||||||
"""
|
"""
|
||||||
|SELECT data
|
|SELECT data
|
||||||
| FROM groups
|
| FROM `groups`
|
||||||
| WHERE name
|
| WHERE name
|
||||||
""".stripMargin
|
""".stripMargin
|
||||||
|
|
||||||
@ -187,7 +187,7 @@ class MySqlGroupRepository extends GroupRepository with GroupProtobufConversions
|
|||||||
monitor("repo.Group.getGroupByName") {
|
monitor("repo.Group.getGroupByName") {
|
||||||
IO {
|
IO {
|
||||||
logger.debug(s"Getting groups with name: $nameFilter")
|
logger.debug(s"Getting groups with name: $nameFilter")
|
||||||
val initialQuery = "SELECT data FROM groups WHERE name"
|
val initialQuery = "SELECT data FROM `groups` WHERE name"
|
||||||
val sb = new StringBuilder
|
val sb = new StringBuilder
|
||||||
sb.append(initialQuery)
|
sb.append(initialQuery)
|
||||||
val groupsLike = if (nameFilter.contains('*')) {
|
val groupsLike = if (nameFilter.contains('*')) {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user