From 550e65b657f0eccd513ba91339fb8f0ea3f9fa02 Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期日, 01 一月 2023 16:18:05 +0800
Subject: [PATCH] 1.1.7
---
DataLoader/CS/Importor.cs | 48 +++++++++++++++++++++++++++++++++++++++++++++---
1 files changed, 45 insertions(+), 3 deletions(-)
diff --git a/DataLoader/CS/Importor.cs b/DataLoader/CS/Importor.cs
index d4eed9d..1dcb6a8 100644
--- a/DataLoader/CS/Importor.cs
+++ b/DataLoader/CS/Importor.cs
@@ -1,23 +1,65 @@
锘縰sing DataLoader.Model;
+using Npgsql;
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
+using System.Data.Common;
+using System.IO;
using System.Linq;
using System.Reflection;
-using System.Text;
-using System.Threading.Tasks;
namespace DataLoader.CS
{
public class Importor
{
+ private static PostgreHelper _ph = null;
+
+ public static PostgreHelper Helper
+ {
+ get
+ {
+ if (_ph == null) _ph = new PostgreHelper(DbEnum.langfang);
+
+ return _ph;
+ }
+ }
+
private static readonly string insertMeta = "insert into lf.sys_meta(name, dirid, depid, verid, type, sizes, cs, scale, resolution, gather, batch, descr, create_user) values @name, @dirid, @depid, @verid, @type, @sizes, @cs, @scale, @resolution, @gather, @batch, @descr, @create_user) returning id";
private static readonly string insertMetaFile = "insert into lf.sys_meta_file(name, metaid, fileid, guid, path, sizes, create_user) values (@name, @metaid, @fileid, @guid, @path, @sizes, @create_user)";
+ public static int CountFilesByGuid(string guid)
+ {
+ string sql = "select count(*) from lf.sys_meta_file where guid=@guid";
+ DbParameter dp = new NpgsqlParameter("@guid", guid);
+
+ int rows = Helper.GetCount(sql, dp);
+
+ return rows;
+ }
+
+ public static int InsertMeta(SysMeta meta)
+ {
+ // string sql = "INSERT INTO public.data_files(mid, guid, name, ext, path, subs, remark) VALUES (@mid, @guid, @name, @ext, @path, @subs, @remark) returning id";
+ List<DbParameter> list = Tool.GetParams<SysMeta>(insertMeta, meta);
+
+ object obj = Helper.GetScalar(insertMeta, list.ToArray());
+
+ return obj == null ? 0 : Convert.ToInt32(obj);
+ }
+
+ public static int InsertMetaFile(SysMetaFile metaFile)
+ {
+ List<DbParameter> list = Tool.GetParams<SysMetaFile>(insertMetaFile, metaFile);
+
+ object obj = Helper.ExecuteNonQuery(insertMetaFile, list.ToArray());
+
+ return obj == null ? 0 : Convert.ToInt32(obj);
+ }
+
public static void Import(ObservableCollection<ViewData> viewDatas, string source, string target)
{
-
+ string[] files = Directory.GetFiles(source);
}
}
}
--
Gitblit v1.9.3