C#实现Oracle的交互(数据库备份与管理)

using System;
using Oracle.DataAccess.Client;

namespace CSharpOracleExample
{
    class Program
    {
        static void Main(string[] args)
        {
            string connectionString = "Data Source=ORACLE_DB;User Id=your_username;Password=your_password;";
            OracleConnection conn = new OracleConnection(connectionString);
            try
            {
                conn.Open();
                string sql = "SELECT * FROM your_table";
                OracleCommand cmd = new OracleCommand(sql, conn);
                OracleDataReader reader = cmd.ExecuteReader();
                while (reader.Read())
                {
                    // 处理每一行数据
                }
                reader.Close();
            }
            catch (Exception ex)
            {
                Console.WriteLine("Error: " + ex.Message);
            }
            finally
            {
                if (conn.State == System.Data.ConnectionState.Open)
                {
                    conn.Close();
                }
            }
        }
    }
}

<connectionStrings>
    <add name="OracleDB" 
         connectionString="User Id=your_username;Password=your_password;Data Source=your_database_service_name;" 
         providerName="Oracle.DataAccess.Client" />
</connectionStrings>

using Oracle.DataAccess.Client;

class Program
{
    static void Main(string[] args)
    {
        string constr = ConfigurationManager.ConnectionStrings["OracleDB"].ConnectionString;
        using (OracleConnection con = new OracleConnection(constr))
        {
            try
            {
                con.Open();
                Console.WriteLine("Connection is established");
            }
            catch (Exception ex)
            {
                Console.WriteLine("Error: " + ex.Message);
            }
        }
    }
}

using Oracle.DataAccess.Client;

OracleConnection con = new OracleConnection();
con.ConnectionString = "User Id=your_username;Password=your_password;Data Source=your_database_service_name;";
try
{
    con.Open();
    Console.WriteLine("Database connection is successfully opened.");
}
catch (Exception ex)
{
    Console.WriteLine("Error: " + ex.Message);
}
finally
{
    con.Close();
}

OracleCommand cmd = new OracleCommand("SELECT * FROM Employees", con);
OracleDataReader reader = cmd.ExecuteReader();

while (reader.Read())
{
    Console.WriteLine(reader.GetString(0)); // 假设第一列是字符串类型
}
reader.Close();

OracleCommand cmd = new OracleCommand("GetEmployeeDetails", con);
cmd.CommandType = CommandType.StoredProcedure;

OracleParameter outputParameter = cmd.Parameters.Add("EmpName", OracleDbType.Varchar2);
outputParameter.Direction = ParameterDirection.Output;

cmd.ExecuteNonQuery();

Console.WriteLine("Employee Name: " + outputParameter.Value);

using Oracle.DataAccess.Client;
using Oracle.DataAccess.Types;

// 创建连接和OracleBulkCopy对象
using (OracleConnection conn = new OracleConnection("Data Source=your_data_source;User Id=your_username;Password=your_password;"))
{
    conn.Open();
    OracleBulkCopy bulkCopy = new OracleBulkCopy(conn);

    // 设置目标表名和批量操作选项
    bulkCopy.DestinationTableName = "your_target_table_name";
    bulkCopy.BatchSize = 100; // 批量操作的大小

    // 准备要批量插入的数据
    DataTable table = new DataTable("your_table_name");
    table.Columns.Add("Column1", typeof(int));
    table.Columns.Add("Column2", typeof(string));

    // 添加数据行
    for (int i = 1; i <= 1000; i++)
    {
        table.Rows.Add(i, "Data " + i);
    }

    // 执行批量插入
    bulkCopy.WriteToServer(table);
    conn.Close();
}

OracleConnection con = new OracleConnection("User Id=your_username;Password=your_password;Data Source=your_data_source;");
con.Open();

OracleTransaction tx = con.BeginTransaction();

try
{
    OracleCommand cmd = con.CreateCommand();
    cmd.Transaction = tx;

    // 执行SQL操作
    cmd.CommandText = "INSERT INTO Employees (Id, Name) VALUES (1, 'John Doe')";
    cmd.ExecuteNonQuery();
    cmd.CommandText = "UPDATE Employees SET Salary = 5000 WHERE Id = 1";
    cmd.ExecuteNonQuery();

    // 提交事务
    tx.Commit();
    Console.WriteLine("Transaction is committed.");
}
catch (Exception ex)
{
    // 回滚事务
    tx.Rollback();
    Console.WriteLine("Transaction is rolled back.");
}
finally
{
    con.Close();
}

-- 文件名: backup.sql
-- 备份目的: 逻辑备份示例
-- 作者: your_name
-- 创建日期: 2023-03-10

/* 创建表结构 */
CREATE TABLE backup_table (
    id INT PRIMARY KEY,
    data VARCHAR(255)
);

/* 插入测试数据 */
INSERT INTO backup_table VALUES (1, 'Sample Data');

-- 清理环境
DROP TABLE backup_table;

-- 授予用户对备份表的SELECT权限
GRANT SELECT ON backup_table TO user_name;

-- 收回用户对备份表的DELETE权限
REVOKE DELETE ON backup_table FROM user_name;

using (OracleConnection conn = new OracleConnection(connectionString))
{
    conn.Open();
    using (OracleCommand cmd = conn.CreateCommand())
    {
        cmd.CommandText = "SELECT * FROM users WHERE user_id = :userId";
        cmd.Parameters.AddWithValue(":userId", 1);
        using (OracleDataReader reader = cmd.ExecuteReader())
        {
            while (reader.Read())
            {
                string userName = reader.GetString(0);
                int age = reader.GetInt32(1);
                Console.WriteLine($"User Name: {userName}, Age: {age}");
            }
        }
    }
}

try
{
    // 执行数据库命令
}
catch (OracleException ex)
{
    // 错误处理代码
}

try
{
    // 尝试执行的代码
}
catch (OracleException ex)
{
    // 处理Oracle相关的异常
}
catch (Exception ex)
{
    // 处理其他所有异常
}
finally
{
    // 不管是否发生异常都会执行的代码，通常用于清理资源
}

catch (OracleException ex)
{
    Console.WriteLine("Oracle Exception: " + ex.Message);
    Console.WriteLine("Stack Trace: " + ex.StackTrace);
}

using System.IO;
using System.IO.Compression;
using System.Security.Cryptography;
using System.Text;

public void BackupAndEncrypt(string sourceFolder, string destinationFile)
{
    // 假设已经从sourceFolder获取了所有需要备份的文件
    using (FileStream originalFileStream = new FileStream(sourceFolder, FileMode.Open, FileAccess.Read))
    using (FileStream compressedFileStream = new FileStream(destinationFile, FileMode.Create))
    using (GZipStream compressionStream = new GZipStream(compressedFileStream, CompressionMode.Compress))
    {
        originalFileStream.CopyTo(compressionStream);
    }

    // 加密压缩后的备份文件
    string key = "your-encryption-key";
    using (Aes myAes = Aes.Create())
    {
        myAes.Key = Encoding.UTF8.GetBytes(key);
        myAes.IV = new byte[16];
        using (FileStream fileToEncrypt = File.OpenRead(destinationFile + ".gz"))
        using (FileStream encryptedFileStream = new FileStream(destinationFile + ".gz.enc", FileMode.Create))
        using (CryptoStream cryptoStream = new CryptoStream(encryptedFileStream, myAes.CreateEncryptor(), CryptoStreamMode.Write))
        {
            fileToEncrypt.CopyTo(cryptoStream);
        }
    }
}

using System;
using System.Threading;

public class BackupTask
{
    private Timer _timer;

    public BackupTask()
    {
        // 创建定时器，定时器回调方法为BackupMethod，首次触发时间为30秒后，之后每1小时触发一次
        _timer = new Timer(BackupMethod, null, TimeSpan.FromSeconds(30), TimeSpan.FromHours(1));
    }

    private void BackupMethod(object state)
    {
        // 此处是备份逻辑，可以调用备份函数 BackupDatabase()
        BackupDatabase();
    }

    private void BackupDatabase()
    {
        // 执行备份的代码逻辑
        Console.WriteLine("Backup is running...");
    }
}

public class Program
{
    public static void Main()
    {
        new BackupTask();
        // 让主线程继续运行，否则程序会立即退出
        Console.WriteLine("Press any key to exit...");
        Console.ReadKey();
    }
}

using System;
using System.IO;
using System.Threading;

public class DatabaseBackupTask
{
    public void StartBackupSchedule()
    {
        // 假定备份脚本路径和参数
        string backupScriptPath = @"C:\BackupScripts\Backup.sql";
        string backupFilePath = @"D:\Backups\Backup.bak";

        // 创建定时器
        Timer backupTimer = new Timer(BackupDatabase, null, TimeSpan.Zero, TimeSpan.FromHours(1));

        Console.WriteLine("Backup schedule started, press Ctrl+C to stop.");
        Console.ReadKey();
    }

    private void BackupDatabase(object state)
    {
        // 执行备份命令
        string argument = $"-s ServerName -d DatabaseName -u Username -p Password -f \"{backupFilePath}\"";
        ProcessStartInfo processInfo = new ProcessStartInfo("SqlCmd.exe", argument)
        {
            RedirectStandardOutput = true,
            RedirectStandardError = true,
            UseShellExecute = false,
            CreateNoWindow = true
        };

        Process process = Process.Start(processInfo);
        process.WaitForExit();
    }
}

public class Program
{
    public static void Main()
    {
        new DatabaseBackupTask().StartBackupSchedule();
    }
}