asp.net開發(fā)sql server轉換成oracle的方法詳解

更新時間：2017年08月24日 10:32:09 作者：老-顧

這篇文章主要給大家介紹了關于asp.net開發(fā)中sql server轉換成oracle的相關資料，文中通過示例代碼和圖文將實現(xiàn)的步驟一步步介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面來一起學習學習吧。

前言

因為前段時間我們公司項目要把sql server 轉oracle，發(fā)現(xiàn)網(wǎng)上這方面的資料較少，所以在這里分享一下心得，也記錄一下問題，下面話不多說了，來一起看看詳細的介紹：

開始我研究了一段時間然后下載了

oracle 11g 版本和 PL/SQL（客戶端）和sql server 不同的是 oracle 沒有自己的客戶端需要用第三方的軟件運行 PL/SQL 就是一個 sqldeveloper 也是一個，PL/SQL 我覺得比較穩(wěn)定一點。但是2個都安裝的話剛好互補了

oracle 容易出現(xiàn) 無監(jiān)聽什么的錯誤可以參考

http://www.dhdzp.com/article/91184.htm

然后再用

創(chuàng)建表空間和用戶這些網(wǎng)上都找得到的

好了東西都安裝好了下面開始 sql server 轉 oracle

首先是數(shù)據(jù)庫的轉換我試了很多種方式，都是多多少少都是有點問題，因為是2個不同的數(shù)據(jù)庫，最后我還是決定自己寫個程序轉換

代碼貼出來

鏈接字符串

<add key="OracleConnectionString" value="Password=123;User ID=SA;Data Source=(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=localhost )(PORT=1521)))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME=ORCL)))"/>
 
 <add key="SqlServerConnectionString" value="server=localhost;database=Table;uid=sa;pwd=123"/>

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Data.OracleClient;
using System.Data.SqlClient;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace TransplantSQL
{
 public partial class Form1 : Form
 {
 public static string OracleConnectionString = System.Configuration.ConfigurationSettings.AppSettings["OracleConnectionString"];
 public static string SqlServerConnectionString = System.Configuration.ConfigurationSettings.AppSettings["SqlServerConnectionString"];
 public Form1()
 {
  InitializeComponent();
 }

 private void button2_Click(object sender, EventArgs e)
 {
  OracleConnection con = new OracleConnection(OracleConnectionString);
  try
  {
  con.Open();
  if (con.State == System.Data.ConnectionState.Open)
  {
   label5.Text = "連接成功";
  }
  }
  catch (OracleException se)
  {
  label5.Text = "連接失敗";
  }

  finally
  {
  con.Close();
  }
 }

 private void button3_Click(object sender, EventArgs e)
 {
  SqlConnection con = new SqlConnection(SqlServerConnectionString);
  try
  {
  con.Open();
  if (con.State == System.Data.ConnectionState.Open)
  {
   label4.Text = "連接成功";
  }
  }
  catch (SqlException se)
  {
  label4.Text = "連接失敗";
  }

  finally
  {
  con.Close();
  }
 }

 private void button1_Click(object sender, EventArgs e)
 {
  if (textBox1.Text == "")
  {
  DataTable tablenames = GetTableNames();
  foreach (DataRow item in tablenames.Rows)
  {
   string tablename = item["Name"].ToString().ToUpper();
   setdata(tablename);
  }
  }
  else
  {
  setdata(textBox1.Text);
  }

  label2.Text = "成功";
 }

 private static void setdata(string tablename)
 {
  // 查找有沒有此表 如果沒有就加
  int et = Convert.ToInt32(GetSingle("select count(*) from user_tables where table_name = '" + tablename + "'"));
  if (et <= 0)
  {
  DataTable tableInfo = GetTableInfo(tablename);
  string addtablesql = "CREATE TABLE {0}({1})";
  string cs = string.Empty;
  string biaoshi = string.Empty;
  foreach (DataRow citem in tableInfo.Rows)
  {
   cs += citem["字段名"].ToString();
   if (citem["類型"].ToString() == "int" || citem["類型"].ToString() == "bit" || citem["類型"].ToString() == "decimal")
   {
   cs += " NUMBER(" + (Convert.ToInt32(citem["長度"]) > 38 ? 38 : Convert.ToInt32(citem["長度"])) + (Convert.ToInt32(citem["小數(shù)位數(shù)"])>0?(","+Convert.ToInt32(citem["小數(shù)位數(shù)"])):"") + ")";
   }
   else if (citem["類型"].ToString() == "nvarchar" || citem["類型"].ToString() == "float")
   {
   cs += " VARCHAR2(" + (Convert.ToInt32(citem["長度"]) == -1 ? 4000 : Convert.ToInt32(citem["長度"]) * 2) + ")";
   }
   else if (citem["類型"].ToString() == "datetime")
   {
   cs += " DATE";
   }
   
   cs += citem["主鍵"].ToString() == "1" ? " primary key " : "";
   if (citem["標識"].ToString() == "1")
   {
   biaoshi = citem["字段名"].ToString();
   }
   cs += citem["默認值"].ToString() != "" ? " default " + citem["默認值"].ToString() + " " : "";
   cs += citem["允許空"].ToString() == "1" ? "," : " NOT NULL,";
  }
  cs = cs.Substring(0, cs.Length - 1);
  string tempsql = string.Format(addtablesql, tablename, cs);
  GetSingle(tempsql);
  if (biaoshi != string.Empty)
  {
   #region 判斷是否有序列號 沒有就創(chuàng)建 就是自動標識
   int xuliehao = 0;
   try
   {
   xuliehao = Convert.ToInt32(GetSingle(string.Format(@"select Seq_{0}.nextval from sys.dual", tablename)));
   }
   catch { }
   if (xuliehao <= 0)
   {
   #region 為了讓序列不重復 取最大值為min 值
   int max = Convert.ToInt32(GetSingle(string.Format("select max({1}) from {0}", tablename, biaoshi),null));
   #endregion
   string sequence = string.Format(@"create sequence Seq_{0} start with {1} increment by 1 nomaxvalue minvalue 1 nocycle nocache", tablename, (max+1));//創(chuàng)建標識
   GetSingle(sequence);
   }
   #endregion
   #region 創(chuàng)建序列的觸發(fā)器
   string chufaqisql = string.Format(@"CREATE OR REPLACE TRIGGER T_{0} 
      BEFORE INSERT ON {0} FOR EACH ROW WHEN (new.{1} is null)
      begin
      select Seq_{0}.nextval into:new.{1} from dual;
      end;", tablename, biaoshi);//創(chuàng)建觸發(fā)器
   GetSingle(chufaqisql);
   #endregion
   #region 創(chuàng)建唯一約束
   //string weiyisql = string.Format(@"create unique index U_{0} on {0} ({1})", tablename, biaoshi);
   //GetSingle(weiyisql);
   #endregion
  }
  //int count = Convert.ToInt32(GetSingle("SELECT count(1) FROM " + tablename));
  //if (count < 10000)
  //{
  DataSet ds = Query("SELECT * FROM " + tablename);
  DataTable dt = ds.Tables[0];
  string columnsNames = string.Empty;
  string values = string.Empty;
  for (int i = 0; i < dt.Columns.Count; i++)
  {
   columnsNames += dt.Columns[i].ColumnName + ",";

  }
  columnsNames = columnsNames.Substring(0, columnsNames.Length - 1);
  foreach (DataRow dr in dt.Rows)
  {
   values = string.Empty;
   for (int i = 0; i < dt.Columns.Count; i++)
   {
   if (dr[i] != DBNull.Value)
   {
    if (dr[i].ToString() != "")
    {
    if (dt.Columns[i].DataType == Type.GetType("System.Double")
     || dt.Columns[i].DataType == Type.GetType("System.Decimal")
     || dt.Columns[i].DataType == Type.GetType("System.Int32"))
    {
     values += dr[i] + ",";
    }
    else if (dt.Columns[i].DataType == Type.GetType("System.String"))
    {
     values += "'" + dr[i].ToString().Replace('\'', '‘') + "',";
    }
    else if (dt.Columns[i].DataType == Type.GetType("System.DateTime"))
    {
     values += "to_date('" + dr[i] + "','YYYY/MM/DD HH24:MI:SS'),";
    }
    else if (dt.Columns[i].DataType == Type.GetType("System.Boolean"))
    {
     if (dr[i].ToString() == "False")
     {
     values += "0,";
     }
     else { values += "1,"; }
    }
    }
    else
    {
    values += "chr(32),";
    }
   }
   else
   {
    values += "NULL,";
   }
   }
   values = values.Substring(0, values.Length - 1);
   string osql = "Insert into " + tablename + "(" + columnsNames + ") values(" + values + ")";
   GetSingle(osql);
  }
  //}
  }
 }

 private static DataTable GetTableNames()
 {
  string sql = string.Format(@"SELECT Name FROM SysObjects Where XType='U' ORDER BY Name");
  DataSet ds = Query(sql);
  return ds.Tables[0];
 }
 private static DataTable GetTableInfo(string tableName)
 {
  string sql = string.Format(@"SELECT (case when a.colorder=1 then d.name else null end) 表名, 
  a.colorder 字段序號,a.name 字段名,
  (case when COLUMNPROPERTY( a.id,a.name,'IsIdentity')=1 then '1'else '' end) 標識, 
  (case when (SELECT count(*) FROM sysobjects 
  WHERE (name in (SELECT name FROM sysindexes 
  WHERE (id = a.id) AND (indid in 
  (SELECT indid FROM sysindexkeys 
  WHERE (id = a.id) AND (colid in 
  (SELECT colid FROM syscolumns WHERE (id = a.id) AND (name = a.name))))))) 
  AND (xtype = 'PK'))>0 then '1' else '' end) 主鍵,b.name 類型,a.length 占用字節(jié)數(shù), 
  COLUMNPROPERTY(a.id,a.name,'PRECISION') as 長度, 
  isnull(COLUMNPROPERTY(a.id,a.name,'Scale'),0) as 小數(shù)位數(shù),(case when a.isnullable=1 then '1'else '' end) 允許空, 
  REPLACE(REPLACE(isnull(e.text,''),'(',''),')','') 默認值,isnull(g.[value], ' ') AS [說明]
  FROM syscolumns a 
  left join systypes b on a.xtype=b.xusertype 
  inner join sysobjects d on a.id=d.id and d.xtype='U' and d.name<>'dtproperties' 
  left join syscomments e on a.cdefault=e.id 
  left join sys.extended_properties g on a.id=g.major_id AND a.colid=g.minor_id
  left join sys.extended_properties f on d.id=f.class and f.minor_id=0
  where b.name is not null
  And d.name='{0}' 
  order by a.id,a.colorder", tableName);
  DataSet ds = Query(sql);
  return ds.Tables[0];
 }

 public static DataSet Query(string SQLString)
 {
  using (SqlConnection connection = new SqlConnection(SqlServerConnectionString))
  {
  DataSet ds = new DataSet();
  try
  {
   connection.Open();
   SqlDataAdapter command = new SqlDataAdapter(SQLString, connection);
   command.Fill(ds, "ds");
  }
  catch (System.Data.SqlClient.SqlException ex)
  {
   throw new Exception(ex.Message);
  }
  return ds;
  }
 }

 public static object GetSingle(string SQLString)
 {
  using (OracleConnection connection = new OracleConnection(OracleConnectionString))
  {
  using (OracleCommand cmd = new OracleCommand())
  {
   try
   {
   PrepareCommand(cmd, connection, null, SQLString, null);
   object obj = cmd.ExecuteScalar();
   cmd.Parameters.Clear();
   if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
   {
    return null;
   }
   else
   {
    return obj;
   }
   }
   catch (OracleException e)
   {
   throw e;
   }
  }
  }
 }

 private static void PrepareCommand(OracleCommand cmd, OracleConnection conn, OracleTransaction trans, string cmdText, OracleParameter[] cmdParms)
 {
  if (conn.State != ConnectionState.Open)
  conn.Open();
  cmd.Connection = conn;
  cmd.CommandText = cmdText;
  if (trans != null)
  cmd.Transaction = trans;
  cmd.CommandType = CommandType.Text;//cmdType;
  if (cmdParms != null)
  {


  foreach (OracleParameter parameter in cmdParms)
  {
   if ((parameter.Direction == ParameterDirection.InputOutput || parameter.Direction == ParameterDirection.Input) &&
   (parameter.Value == null))
   {
   parameter.Value = DBNull.Value;
   }
   cmd.Parameters.Add(parameter);
  }
  }
 }

 public static object GetSingle(string SQLString, params SqlParameter[] cmdParms)
 {
  using (SqlConnection connection = new SqlConnection(SqlServerConnectionString))
  {
  using (SqlCommand cmd = new SqlCommand())
  {
   try
   {
   PrepareCommand(cmd, connection, null, SQLString, cmdParms);
   object obj = cmd.ExecuteScalar();
   cmd.Parameters.Clear();
   if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
   {
    return null;
   }
   else
   {
    return obj;
   }
   }
   catch (System.Data.SqlClient.SqlException e)
   {
   throw e;
   }
  }
  }
 }

 private static void PrepareCommand(SqlCommand cmd, SqlConnection conn, SqlTransaction trans, string cmdText, SqlParameter[] cmdParms)
 {
  if (conn.State != ConnectionState.Open)
  conn.Open();
  cmd.Connection = conn;
  cmd.CommandText = cmdText;
  if (trans != null)
  cmd.Transaction = trans;
  cmd.CommandType = CommandType.Text;//cmdType;
  if (cmdParms != null)
  {


  foreach (SqlParameter parameter in cmdParms)
  {
   if ((parameter.Direction == ParameterDirection.InputOutput || parameter.Direction == ParameterDirection.Input) &&
   (parameter.Value == null))
   {
   parameter.Value = DBNull.Value;
   }
   cmd.Parameters.Add(parameter);
  }
  }
 }
 }
}

這個代碼適應于我的數(shù)據(jù)庫轉換大家需要的話可以修改一下

其中oracle 沒有自增長的，，而是序列另外序列可以用觸發(fā)器觸發(fā) 麻煩了一點整的來說還算好啦

然后就是把我原來的程序字符串鏈接改成oracle 的鏈接上面貼出來了

首先System.Data.SqlClient;引用改成System.Data.OracleClient;

然后在看報錯的地方通通改掉就行了從Sql 改為 Oracle 就行

然后我貼出一些不報錯但是sqlserver 和oracle 不同的地方

查詢前多少條數(shù)據(jù)

select * from (SELECT * FROM Table) where rownum<100

其他格式轉化成字符串格式

select to_char(其他格式,字符串格式) 如select to_char(sysdate,'yyyy-mm-dd') from dual

字符串截取

（截取的字符串，開始的位置，長度）

select substr('111222',3,2) from dual

字符串格式轉化為時間格式

select to_date('2017-08-03','yyyy-mm-dd') from dual

sql參數(shù)化占位符，不能用@用:

SELECT * FROM Table where ID=:ID

系統(tǒng)時間

getdate()改成sysdate

獲取當前自動增長列ID

select Seq_Table.currval from dual

Seq_Table是自動增長列的名字，每個表都不一樣，所以需要找到當前

表設置的自動增長列對應的名字

都改完之后等程序不報錯了運行

會出現(xiàn)32和64位的什么破問題網(wǎng)上各種說法的都有說項目屬性中改成 X86 X64

但是這些對我都不管用并且我覺得這些東西改了之后會對我原有的項目造成很多問題

所以我研究了很久最終得出幾個結果

首先如果是控制臺或窗體程序的話直接把項目中首選32位勾上就行了

如果是 asp.net 頁面程序就沒這么簡單了

我本機是64位系統(tǒng) 然后我安裝oracle 和客戶端都是64位按道理不應該給我報什么64位錯啊

然后網(wǎng)上說要安裝32位Instant Client Setup

然后我就下了一個安裝了程序就可以了，

但是我在服務器上面再次用同樣的方法又不行了，找了很多資料最終重新安裝了一下iis好了（其實是要重新注冊一遍framework）

安裝32位的版本最好和oracle 版本一樣

那時候我下了很多個版本調試有的時候安裝 Instant Client Setup的時候會卡在一個點不動，可以多試幾次如果還是不行在重新找一個吧！

安裝完后在控制面板里面可以找到的

另外貼出備份還原的命令用CMD打開運行修改對應參數(shù)

Exp sa/123@ORCL file=C:\OracleBack\back_%date:~0,4%%date:~5,2%%date:~8,2%.dmp owner=sa

IMP sa/123 BUFFER=64000 FILE=C:\OracleBack\back_20170821.dmp FROMUSER=SA TOUSER=SA

總結

以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作能帶來一定的幫助，如果有疑問大家可以留言交流，謝謝大家對腳本之家的支持。

您可能感興趣的文章:

.net框架(framework)版本不匹配的解決方法
.net框架(framework)版本不匹配的解決方法，需要的朋友可以參考一下
2013-03-03
測試控制臺使用方法
如何使用測試控制臺，需要的朋友可以參考下。
2009-11-11
淺談ASP.NET Core 2.0 帶初始參數(shù)的中間件(譯)
這篇文章主要介紹了淺談ASP.NET Core 2.0 帶初始參數(shù)的中間件(譯)，非常具有實用價值，需要的朋友可以參考下
2017-10-10
實現(xiàn)Asp與Asp.Net共享Session的方法
這篇文章主要介紹了實現(xiàn)Asp與Asp.Net共享Session的方法,需要的朋友可以參考下
2014-08-08
asp.net 2.0多語言網(wǎng)站解決方法
asp.net 2.0中的App_GlobalResources可以用來解決本地化的問題，程序會根據(jù)瀏覽器的語言首選項自動判斷顯示出本地化的界面。
2008-09-09
ASP.NET解決上傳大文件問題的方法
ASP.NET解決上傳大文件問題的方法，需要的朋友可以參考一下
2013-03-03
模擬QQ心情圖片上傳預覽示例
目前js端不支持獲取本地圖片進行預覽，正好在做一款類似于QQ心情的發(fā)布框，找了不少jquery插件，先粘上以下插件，感興趣的朋友可以參考下
2013-08-08
ASP.NET XmlHttp跨域訪問實現(xiàn)代碼
最近項目需要實現(xiàn)XmlHttp的POST方法到另一服務器上的頁面進行數(shù)據(jù)的更新，可是IE會提出“該頁正在訪問其控制范圍之外的信息，是否繼續(xù)?”等警告信息，而在其他瀏覽器上直接禁止掉，GOOGLE一下原來是XmlHttp的跨域訪問問題，找了很多資料，說是提供很多解決方案，可是都沒有用處。
2008-11-11
.NET?CORE?鑒權的實現(xiàn)示例
本文主要介紹了.NET?CORE?鑒權的實現(xiàn)示例，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2022-02-02
一次.net?core異步線程設置超時時間的實戰(zhàn)記錄
這篇文章主要給大家介紹了關于.net?core異步線程設置超時時間的相關資料,文中通過實例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
2022-02-02