--创建表
declare num number; begin select count(1) into num from user_tables where table_name=‘SRCT‘; --判断当前要创建的表在数据库中是否存在.if num>0 then execute immediate ‘drop table ‘||‘SRCT‘; --表名要大写end if; execute immediate ‘CREATE TABLE SRCT( SN char(11), XM varchar2(30), --姓名 KSCJ number(3), --考试成绩 KSRQ Date --考试日期 )‘; end;/commit;/--注:上面的表名要大写.
--插入数据declaremaxrecords constant int:=50;i int:=1;beginfor i in 1..maxrecordsloopinsert into SRCT(SN,XM,KSCJ,KSRQ)values(i,‘frj‘||i,i+10,sysdate);end loop--dbms_output.put_line(‘成功录入数据!‘);commit;end;/--查询数据,检查数据插入操作是否成功.SELECT * FROM SRCT WHERE ROWNUM<3;/
--检查存储过程是否存在declare num number;msg varchar2(30):= ‘数据库中不存在该存储过程‘;begin select count(1) into num from user_objects where object_type = ‘PROCEDURE‘ and object_name=‘WRITE_SRC‘ ; if num>0 then msg:= ‘该存储过程已经存在‘; end if; dbms_output.put_line(msg); end ;/
--创建存储过程CREATE OR REPLACE Procedure WRITE_SRC( M_SN in char , M_XM in varchar2,M_KSCJ in integer,M_KSRQ in Date,RES out integer,ERR outvarchar2)asV_COUNT number:=0; Begin RES:=-2; ERR:=‘数据库中不存在该纪录,更新失败.‘; select count(SN) INTO V_COUNT FROM SRCT Where SN=M_SN AND XM=M_XM; IF V_COUNT>0 THEN Update SRCT Set KSCJ=M_KSCJ,KSRQ=M_KSRQ Where SN=M_SN AND XM=M_XM; Commit; RES:=1; ERR:=‘更新成功!‘; return; END IF; exception when others then RES:=-1; ERR:=‘更新失败‘; return ;End ;/commit;/
--调用存储过程declare res int;err Varchar2(80);Beginres:=‘3‘;err:=‘更新成功‘;WRITE_SRC(‘1‘,‘frj1‘,300,sysdate,res,err);COMMIT;dbms_output.put_line(res);dbms_output.put_line(err); End;/select sn,xm,kscj from srct WHERE SN=‘1‘ AND XM=‘frj1‘;/
--注:易犯错误--以上语句均在"SQL*Plus 工作单"上运行; 1.每一个小单元的语句后要加‘;‘号; 2.不能将字符串赋值的单引号写成双引号; 如: err:=‘更新成功!‘; 不能写成 err:="更新成功!"; 以上错误系统将提示:"警告: 创建的过程带有编译错误。" 3.存储过程传递与赋值的参数名称,个数,类型(字段类型，返回的类型(in/out))要与调用的存储过程以及该存储过程 所访问的表中相应的字段类型严格对应. 还有一些约定的写法也需遵守. 如:其中的" M_KSCJ "对应表中的" KSCJ "字段, 应写成(M_KSCJ in integer)不能写成( M_KSCJ in number(3)); "M_SN"对应表中的 "SN" 字段,应写成 (M_SN in char) 不能写成 (M_SN in Varchar2) 4.在c#中进行调用时,还要注意它的输入/输出类型,如上例中的" out integer res " 为输出类型,应将其 OracleParameter[] parm = new OracleParameter[1]; parm[0] = new OracleParameter("RES", OracleType.Int16 ); parm[0].Direction = ParameterDirection.Output ; --将其设为输出类型; 具体调用方法将在稍后进行介绍; 5.定义存储过程时,其参数名称最好不要与字段名称同名(不区分大小写); 如上面的存储过程建议不要写成: WRITE_SRC( SN in char , XM in varchar2,KSCJ in integer, KSRQ in Date,RES out integer,ERR out varchar2)
//--在c#中的调用 public int upInfo(string m_sn,string m_sxm,int m_ikscj,DateTime m_dksrq, out int m_ires, out string m_serr)
{
string ConnStr=GetConnStr(); OracleCommand cmd = new OracleCommand(); OracleConnection conn = new OracleConnection(ConnStr); int rows = 0; mres = -110; merr = ""; try
{ cmd.CommandType = CommandType.StoredProcedure; cmd.CommandText = "WRITE_SRC"; OracleParameter[] parm = new OracleParameter[6]; //in parm[0] = new OracleParameter("M_SN", OracleType.Char, 11); --与SQL区别,sql存储过程需要在定义与此处,在其参数前加"@"符号; parm[1] = new OracleParameter("M_XM", OracleType.VarChar, 2); parm[2] = new OracleParameter("M_KSCJ", OracleType.Number, 3); parm[3] = new OracleParameter("M_KSRQ", OracleType.DateTime , 8); //out parm[4] = new OracleParameter("RES", OracleType.Int16); parm[5] = new OracleParameter("ERR", OracleType.VarChar, 50); //指明参数是输入还是输出型 for (int i = 0; i < parm.Length-2; i++) { parm[i].Direction = ParameterDirection.Input;
} parm[4].Direction = ParameterDirection.Output; parm[5].Direction = ParameterDirection.Output; //给参数赋值 parm[0].Value = m_sn; parm[1].Value = m_sxm; parm[2].Value = m_ikscj; parm[3].Value = OracleDateTime.Parse(m_dksrq.ToShortDateString()); --直接用update语句更新时,需要采用下面的日期格式. -- string msksrq = mksrq.Day.ToString() + "-" + mksrq.Month.ToString() + "月" + " -" + mksrq.Year.ToString().Substring(2, 2); //传递参数给Oracle命令 for (int i = 0; i < parm.Length; i++) { cmd.Parameters.Add(parm[i]); } //打开连接 if (conn.State != ConnectionState.Open) conn.Open(); cmd.Connection = conn; rows = cmd.ExecuteNonQuery(); //取出返回值 m_ires = Convert.ToInt16(parm[4].Value);//res m_serr = parm[5].Value.ToString();//err } catch (Exception er) { merr = System.Environment.NewLine + "res:" + m_ires.ToString() + "err:" + er.ToString(); MrfuWriteEventLog.C_WriterEventLog.WriteEventLogAppend("UploadDriInfo: mres=" + m_ires.ToString() + "merr:" + er.ToString()); } finally { //关闭连接,释放空间. if (conn.State == ConnectionState.Open) conn.Close(); conn.Dispose(); cmd.Parameters.Clear(); cmd.Dispose(); } return rows;
}
--按时间段分页显示 select sn,xm,kscj,ksrq from SRCT where ksrq between to_date(‘2003-01-01‘,‘yyyy-mm-dd‘) and to_date(‘2007-06-28‘,‘yyyy-mm-dd‘) order by ksrq;/select * from ( select b.*,rownum row_num from ( select sn,xm,kscj,ksrq from SRCT c where ksrq between to_date(‘2003-01-01‘,‘yyyy-mm-dd‘) and to_date(‘2007-06-28‘,‘yyyy-mm-dd‘) order by c.sn )b)a where a.row_num between 1 and 10; /--注: oracle的rownum是在提取记录时就已经生成，它先于排序操作，所以必须使用子查询先排序.
--==转oracle分页存储过程==CREATE OR REPLACE PACKAGE DotNet is TYPE type_cur IS REF CURSOR; --定义游标变量用于返回记录集 PROCEDURE DotNetPagination ( Pindex in number, --分页索引 Psql in varchar2, --产生dataset的sql语句 Psize in number, --页面大小 Pcount out number, --返回分页总数 v_cur out type_cur --返回当前页数据记录 ); procedure DotNetPageRecordsCount ( Psqlcount in varchar2, --产生dataset的sql语句 Prcount out number --返回记录总数 );end DotNet;/CREATE OR REPLACE PACKAGE BODY DotNet is --*************************************************************************************** PROCEDURE DotNetPagination ( Pindex in number, Psql in varchar2, Psize in number, Pcount out number, v_cur out type_cur ) AS v_sql VARCHAR2(1000); v_count number; v_Plow number; v_Phei number; Begin ------------------------------------------------------------取分页总数 v_sql := ‘select count(*) from (‘ || Psql || ‘)‘; execute immediate v_sql into v_count; Pcount := ceil(v_count/Psize); ------------------------------------------------------------显示任意页内容 v_Phei := Pindex * Psize + Psize; v_Plow := v_Phei - Psize + 1; --Psql := ‘select rownum rn,t.* from cd_ssxl t‘ ; --要求必须包含rownum字段 v_sql := ‘select * from (‘ || Psql || ‘) where rn between ‘ || v_Plow || ‘ and ‘ || v_Phei ; open v_cur for v_sql; End DotNetPagination; --************************************************************************************** procedure DotNetPageRecordsCount ( Psqlcount in varchar2, Prcount out number ) as v_sql varchar2(1000); v_prcount number; begin v_sql := ‘select count(*) from (‘ || Psqlcount || ‘)‘; execute immediate v_sql into v_prcount; Prcount := v_prcount; --返回记录总数 end DotNetPageRecordsCount; --**************************************************************************************end DotNet;/
//==使用示例== /**//// <summary> /// 填充dataSet数据集－Oracle库 /// </summary> /// <param name="pindex">当前页</param> /// <param name="psql">执行查询的SQL语句</param> /// <param name="psize">每页显示的记录数</param> /// <returns></returns> private bool gridbind(int pindex, string psql, int psize) { OracleConnection conn = new OracleConnection(); OracleCommand cmd = new OracleCommand(); OracleDataAdapter dr = new OracleDataAdapter(); conn.ConnectionString = System.Configuration.ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString; cmd.Connection = conn; cmd.CommandType = CommandType.StoredProcedure; conn.Open(); cmd.CommandText = "DotNet.DotNetPageRecordsCount"; cmd.Parameters.Add("psqlcount", OracleType.VarChar).Value = psql; cmd.Parameters.Add("prcount", OracleType.Number).Direction = ParameterDirection.Output; cmd.ExecuteNonQuery(); string PCount = cmd.Parameters["prcount"].Value.ToString(); cmd.Parameters.Clear(); cmd.CommandText = "DotNet.DotNetPagination"; if (pindex != 0) { cmd.Parameters.Add("pindex", OracleType.Number).Value = pindex - 1; } else { cmd.Parameters.Add("pindex", OracleType.Number).Value = pindex; } cmd.Parameters.Add("psql", OracleType.VarChar).Value = psql; cmd.Parameters.Add("psize", OracleType.Number).Value = psize; cmd.Parameters.Add("v_cur", OracleType.Cursor).Direction = ParameterDirection.Output; cmd.Parameters.Add("pcount", OracleType.Number).Direction = ParameterDirection.Output; dr.SelectCommand = cmd; try { ds = new DataSet(); dr.Fill(ds); //显示页码条的状态 showStatus(Convert.ToInt32(cmd.Parameters["pindex"].Value) + 1, Convert.ToInt32(cmd.Parameters["pcount"].Value), Convert.ToInt32(PCount)); for (int i = 0; i < ds.Tables.Count; i++) { //把数据行为零的表删除 if (ds.Tables[i].Rows.Count == 0) ds.Tables.Remove(ds.Tables[i].TableName); } } catch (Exception ex) { Console.WriteLine(ex.Message); return false; } conn.Close(); return true; }