aboutsummaryrefslogtreecommitdiff
path: root/Emby.Server.Implementations/Data/SqliteExtensions.cs
diff options
context:
space:
mode:
authorcvium <clausvium@gmail.com>2023-08-21 21:37:18 +0200
committercvium <clausvium@gmail.com>2023-08-21 21:37:18 +0200
commitcf04b43fa4396a67705a2c276cc76d633a075c46 (patch)
tree646f5a2043dfc1f26f1dc9797d8033ffa464dca8 /Emby.Server.Implementations/Data/SqliteExtensions.cs
parentfb511dbae2ccca240e02818f7cba8d6d933fcadd (diff)
simplify extension methods
Diffstat (limited to 'Emby.Server.Implementations/Data/SqliteExtensions.cs')
-rw-r--r--Emby.Server.Implementations/Data/SqliteExtensions.cs40
1 files changed, 1 insertions, 39 deletions
diff --git a/Emby.Server.Implementations/Data/SqliteExtensions.cs b/Emby.Server.Implementations/Data/SqliteExtensions.cs
index 40cecbb6b..14f0f5830 100644
--- a/Emby.Server.Implementations/Data/SqliteExtensions.cs
+++ b/Emby.Server.Implementations/Data/SqliteExtensions.cs
@@ -53,14 +53,6 @@ namespace Emby.Server.Implementations.Data
"yy-MM-dd"
};
- private static void EnsureOpen(this SqliteConnection sqliteConnection)
- {
- if (sqliteConnection.State == ConnectionState.Closed)
- {
- sqliteConnection.Open();
- }
- }
-
public static IEnumerable<SqliteDataReader> Query(this SqliteConnection sqliteConnection, string commandText)
{
if (sqliteConnection.State != ConnectionState.Open)
@@ -81,29 +73,11 @@ namespace Emby.Server.Implementations.Data
public static void Execute(this SqliteConnection sqliteConnection, string commandText)
{
- sqliteConnection.EnsureOpen();
- using var command = sqliteConnection.CreateCommand();
- command.CommandText = commandText;
- command.ExecuteNonQuery();
- }
-
- public static void ExecuteAll(this SqliteConnection sqliteConnection, string commandText)
- {
- sqliteConnection.EnsureOpen();
-
using var command = sqliteConnection.CreateCommand();
command.CommandText = commandText;
command.ExecuteNonQuery();
}
- public static void RunQueries(this SqliteConnection connection, string[] queries)
- {
- ArgumentNullException.ThrowIfNull(queries);
- using var transaction = connection.BeginTransaction();
- connection.ExecuteAll(string.Join(';', queries));
- transaction.Commit();
- }
-
public static string ToDateTimeParamValue(this DateTime dateValue)
{
var kind = DateTimeKind.Utc;
@@ -239,6 +213,7 @@ namespace Emby.Server.Implementations.Data
}
else
{
+ // Blobs aren't always detected automatically
if (isBlob)
{
statement.Parameters.Add(new SqliteParameter(name, SqliteType.Blob) { Value = value });
@@ -250,18 +225,6 @@ namespace Emby.Server.Implementations.Data
}
}
- public static void TryBind(this SqliteCommand statement, string name, byte[] value)
- {
- if (statement.Parameters.Contains(name))
- {
- statement.Parameters[name].Value = value;
- }
- else
- {
- statement.Parameters.Add(new SqliteParameter(name, SqliteType.Blob, value.Length) { Value = value });
- }
- }
-
public static void TryBindNull(this SqliteCommand statement, string name)
{
statement.TryBind(name, DBNull.Value);
@@ -286,7 +249,6 @@ namespace Emby.Server.Implementations.Data
public static SqliteCommand PrepareStatement(this SqliteConnection sqliteConnection, string sql)
{
- sqliteConnection.EnsureOpen();
var command = sqliteConnection.CreateCommand();
command.CommandText = sql;
return command;