两个数据库之间如何互相调用数据

两个数据库之间如何互相调用数据,第1张

首先,你的情况是属于数据数据表之间的一种关联关系,不是你说的两个数据库之间的数据调用。

不好意思,我看错了。

这样的方式,用存储过程处理最简单不过了,先通过查询语句,将B中的user中online的数据值提取出来,赋值给一个临时定义的变量,然后,再对这个变量的值进行判断,如果online=1了,那么执行Update User set EXP=EXP+100 WHERE online=你查询出来的变量的值。

这种方法你可以试试看的。

路过~~

通过数据库响应时间、吞吐量等,进行判断。

1、数据库响应时间指的是当客户端发送请求到数据库时,数据库需要花费的时间来处理请求并返回响应结果。响应时间越短,代表数据库的通信能力越强。

2、吞吐量是指数据库能够处理或传输的数据量或请求的数量。吞吐量越高,代表数据库的通信能力越强。

数据库通信力是指数据库在处理请求、传输数据以及存储数据时所具备的计算资源和网络带宽等技术条件的综合水平。

用db_links可以解决此类问题:

drop database link ss

create database link woody_DB_LINK

connect to woodydb(数据库实例名称)

identified by woody123(密码)

using 'woodywoodycadcom'(连接字符)

然后在oracle安装目录下:D:\oracle\network\ADMIN

tnsnamesora文件里面根据链接情况加上链接

woodywoodyCADCOM =

(DESCRIPTION =

(ADDRESS_LIST =

(ADDRESS = (PROTOCOL = TCP)(HOST = 19216810024)(PORT = 1521))

)

(CONNECT_DATA =

(SERVICE_NAME = woodycom)

)

)

数据库管理系统(DBMS)的主要功能有:1、数据定义功能。2、数据存取功能。3、数据库运行管理功能。4、数据库的建立和维护功能。5、数据库的传输。

1、数据定义功能。DBMS提供相应数据语言来定义(DDL)数据库结构,它们是刻画数据库框架,并被保存在数据字典中。

2、数据存取功能。DBMS提供数据 *** 纵语言(DML),实现对数据库数据的基本存取 *** 作:检索,插入,修改和删除。

3、数据库运行管理功能。DBMS提供数据控制功能,即是数据的安全性、完整性和并发控制等对数据库运行进行有效地控制和管理,以确保数据正确有效。

4、数据库的建立和维护功能。包括数据库初始数据的装入,数据库的转储、恢复、重组织,系统性能监视、分析等功能。

5、数据库的传输。DBMS提供处理数据的传输,实现用户程序与DBMS之间的通信,通常与 *** 作系统协调完成。

不就是 把 串口接收的数据存入 数据库

或者 把 数据库 的 数据 通过串口发送 出去?

其实 ,就是 编程问题

推荐看书

Visual C++_Turbo C串口通信编程实践

Visual_Basic与_RS-232_串行通信控制

using System;

using SystemCollectionsGeneric;

using SystemLinq;

using SystemText;

using SystemDataSqlClient;

using SystemData;

using SystemDataOleDb;

using SystemConfiguration;

namespace Makings

{

class DAL

{

//DataConnection dc = new DataConnection();

private static string strconn = ConfigurationManagerConnectionStrings["MakingsInfo"]ConnectionString;

/// <summary>

/// 显示所有物料的进出情况

/// </summary>

/// <returns></returns>

public static DataTable GetShowBomPass()

{

DataTable dt = new DataTable();

SqlConnection conn = new SqlConnection(strconn);

SqlDataAdapter sda = new SqlDataAdapter("Pro_ShowBomPass", conn);

sdaSelectCommandCommandType = CommandTypeStoredProcedure;

sdaFill(dt);

return dt;

}

public static DataTable GetPassAndOut(string PN, DateTime StartTime, DateTime EndTime)

{

DataTable dt = new DataTable();

SqlConnection conn = new SqlConnection(strconn);

SqlDataAdapter sda = new SqlDataAdapter("CHK_PN", conn);

sdaSelectCommandCommandType = CommandTypeStoredProcedure;

sdaSelectCommandParametersAddWithValue("@PN", PN);

sdaSelectCommandParametersAddWithValue("@StartTime", StartTime);

sdaSelectCommandParametersAddWithValue("@EndTime", EndTime);

sdaFill(dt);

return dt;

}

public static bool GetAdd(string PN, string Category, string Supplier, Single Price, double quantity, bool Operate, string Odd_Number, string Indent_Number, DateTime Time,string Remark)

{

bool result = false;

SqlConnection conn = new SqlConnection(strconn);

SqlCommand com = new SqlCommand("ADD_passAndout", conn);

comCommandType = CommandTypeStoredProcedure;

comParametersAddWithValue("@PN", PN);

comParametersAddWithValue("@Category", Category);

comParametersAddWithValue("@Supplier", Supplier);

comParametersAddWithValue("@Price", Price);

comParametersAddWithValue("@quantity", quantity);

comParametersAddWithValue("@Operate ", Operate);

comParametersAddWithValue("@Odd_Number", Odd_Number);

comParametersAddWithValue("@Indent_Number", Indent_Number);

comParametersAddWithValue("@Time", Time);

comParametersAddWithValue("@Remark",Remark);

connOpen();

result = comExecuteNonQuery() > 0;

connClose();

return result;

}

/// <summary>

/// 显示进出表所有信息

/// </summary>

/// <returns></returns>

public static DataTable GetShowPassOutAll()

{

DataTable dt = new DataTable();

SqlConnection conn = new SqlConnection(strconn);

SqlDataAdapter sda = new SqlDataAdapter("Pro_pass_out", conn);

sdaSelectCommandCommandType = CommandTypeStoredProcedure;

sdaFill(dt);

return dt;

}

/// 获取最后一条记录

/// </summary>

/// <returns></returns>

public static DataTable GetAll()

{

DataTable dt = new DataTable();

SqlConnection conn = new SqlConnection(strconn);

SqlDataAdapter sda = new SqlDataAdapter("CHK_All", conn);

sdaSelectCommandCommandType = CommandTypeStoredProcedure;

sdaFill(dt);

return dt;

}

/// <summary>

/// 根据用户名和密码登录

/// </summary>

/// <param name="Name">用户名</param>

/// <param name="password">密码</param>

/// <returns></returns>

public static bool Login(string Name, string password)

{

bool result = false;

SqlConnection conn = new SqlConnection(strconn);

SqlCommand cmd = new SqlCommand("Login", conn);

cmdCommandType = CommandTypeStoredProcedure;

cmdParametersAddWithValue("@Name", Name);

cmdParametersAddWithValue("@pwd", password);

//cmdParametersAddWithValue("@Ustate", Ustate);

connOpen();

SqlDataReader dr = cmdExecuteReader();

result = drRead();

connClose();

return result;

}

/// <summary>

/// 添加用户信息

/// </summary>

/// <param name="Name">用户名</param>

/// <param name="pwd">密码</param>

/// <returns></returns>

public static bool GetAddUser(string Name, string pwd)

{

bool result = false;

SqlConnection conn = new SqlConnection(strconn);

SqlCommand cmd = new SqlCommand("Add_userInfo", conn);

cmdCommandType = CommandTypeStoredProcedure;

cmdParametersAddWithValue("@Name", Name);

cmdParametersAddWithValue("@pwd", pwd);

connOpen();

result = cmdExecuteNonQuery() > 0;

connClose();

return result;

}

/// <summary>

/// 修改用户密码

/// </summary>

/// <param name="pwd">密码</param>

/// <returns></returns>

public static bool GetUpdateUser(string Name, string pwd)

{

bool result = false;

SqlConnection conn = new SqlConnection(strconn);

SqlCommand cmd = new SqlCommand("Update_PWD", conn);

cmdCommandType = CommandTypeStoredProcedure;

cmdParametersAddWithValue("@Name", Name);

cmdParametersAddWithValue("@pwd", pwd);

connOpen();

result = cmdExecuteNonQuery() > 0;

connClose();

return result;

}

/// <summary>

/// 根据姓名删除用户信息

/// </summary>

/// <param name="Name">用户名</param>

/// <returns></returns>

public static bool GetDeleteUser(string Name)

{

bool result = false;

SqlConnection conn = new SqlConnection(strconn);

SqlCommand cmd = new SqlCommand("Delete_User", conn);

cmdCommandType = CommandTypeStoredProcedure;

cmdParametersAddWithValue("@Name", Name);

connOpen();

result = cmdExecuteNonQuery() > 0;

connClose();

return result;

}

/// <summary>

/// 获取所有的用户信息

/// </summary>

/// <returns></returns>

public static DataTable GetAllUserInfo()

{

DataTable dt = new DataTable();

SqlConnection conn = new SqlConnection(strconn);

SqlDataAdapter sda = new SqlDataAdapter("All_User", conn);

sdaSelectCommandCommandType = CommandTypeStoredProcedure;

sdaFill(dt);

return dt;

}

/// <summary>

/// 显示材料信息

/// </summary>

/// <returns></returns>

public static DataTable GetShowBomAll()

{

DataTable dt = new DataTable();

SqlConnection conn = new SqlConnection(strconn);

SqlDataAdapter sda = new SqlDataAdapter("Pro_ShowBomAll", conn);

sdaSelectCommandCommandType = CommandTypeStoredProcedure;

sdaFill(dt);

return dt;

}

/// <summary>

/// 根据PN查询所有的材料信息

/// </summary>

/// <param name="PN"></param>

/// <returns></returns>

public static DataTable GetAllBOM(string PN)

{

DataTable dt = new DataTable();

SqlConnection conn = new SqlConnection(strconn);

SqlDataAdapter sda = new SqlDataAdapter("select_BOM", conn);

sdaSelectCommandCommandType = CommandTypeStoredProcedure;

sdaSelectCommandParametersAddWithValue("@PN", PN);

sdaFill(dt);

return dt;

}

/// <summary>

/// 添加材料信息

/// </summary>

/// <param name="PN"></param>

/// <param name="Name">材料名称</param>

/// <param name="Standard">规格</param>

/// <param name="Unit">单位</param>

/// <param name="Category">类别</param>

/// <returns></returns>

public static bool GetAddBOM(string PN, string Name, string Standard, string Unit, string Category)

{

bool result = false;

SqlConnection conn = new SqlConnection(strconn);

SqlCommand smd = new SqlCommand("ADD_BOM", conn);

smdCommandType = CommandTypeStoredProcedure;

smdParametersAddWithValue("@PN", PN);

smdParametersAddWithValue("@Name", Name);

smdParametersAddWithValue("@Standard", Standard);

smdParametersAddWithValue("@Unit", Unit);

smdParametersAddWithValue("@Category", Category);

connOpen();

result = smdExecuteNonQuery() > 0;

connClose();

return result;

}

/// <summary>

/// 根据PN删除指定的材料

/// </summary>

/// <param name="PN"></param>

/// <returns></returns>

public static bool GetDeleteBOM(string PN)

{

bool result = false;

SqlConnection conn = new SqlConnection(strconn);

SqlCommand smd = new SqlCommand("delete_BOM", conn);

smdCommandType = CommandTypeStoredProcedure;

smdParametersAddWithValue("@PN", PN);

connOpen();

result = (smdExecuteNonQuery() > 0);

connClose();

return result;

}

/// <summary>

/// 获取所有的物料信息

/// </summary>

/// <returns></returns>

public static DataTable GetAllBOM()

{

DataTable dt = new DataTable();

SqlConnection conn = new SqlConnection(strconn);

SqlDataAdapter sda = new SqlDataAdapter("AllBOM", conn);

sdaSelectCommandCommandType = CommandTypeStoredProcedure;

sdaFill(dt);

return dt;

}

/// <summary>

/// 根据PN删除指定数据

/// </summary>

/// <param name="PN"></param>

/// <returns></returns>

public static bool GetDeletePassAndOut(int id)

{

bool result = false;

SqlConnection conn = new SqlConnection(strconn);

SqlCommand smd = new SqlCommand("Delete_passAndout", conn);

smdCommandType = CommandTypeStoredProcedure;

smdParametersAddWithValue("@ID", id);

connOpen();

result = smdExecuteNonQuery() > 0;

connClose();

return result;

}

public static DataTable GetCHK_PassAndOut(string PN)

{

DataTable dt = new DataTable();

SqlConnection conn = new SqlConnection(strconn);

SqlDataAdapter sda = new SqlDataAdapter("CHK_PassAndout", conn);

sdaSelectCommandCommandType = CommandTypeStoredProcedure;

sdaSelectCommandParametersAddWithValue("@PN", PN);

sdaFill(dt);

return dt;

}

public static DataTable GetCHK_Data(string PN)

{

DataTable dt = new DataTable();

SqlConnection conn = new SqlConnection(strconn);

SqlDataAdapter sda = new SqlDataAdapter("CHK_data", conn);

sdaSelectCommandCommandType = CommandTypeStoredProcedure;

sdaSelectCommandParametersAddWithValue("@PN ", PN);

sdaFill(dt);

return dt;

}

public static DataTable GetCHK_data2(string PN)

{

DataTable dt = new DataTable();

SqlConnection conn = new SqlConnection(strconn);

SqlDataAdapter sda = new SqlDataAdapter("CHK_data2", conn);

sdaSelectCommandCommandType = CommandTypeStoredProcedure;

sdaSelectCommandParametersAddWithValue("@PN", PN);

sdaFill(dt);

return dt;

}

public static DataTable GetRetrieveAllData(string PN, DateTime StartTime, DateTime EndTime)

{

DataTable dt = new DataTable();

SqlConnection conn = new SqlConnection(strconn);

SqlDataAdapter sda = new SqlDataAdapter("RetrieveAllData", conn);

sdaSelectCommandCommandType = CommandTypeStoredProcedure;

sdaSelectCommandParametersAddWithValue("@PN", PN);

sdaSelectCommandParametersAddWithValue("@StartTime", StartTime);

sdaSelectCommandParametersAddWithValue("@EndTime", EndTime);

sdaFill(dt);

return dt;

}

#region 查询进出表所有记录

/// <summary>

/// 获取进出表所有 *** 作记录

/// </summary>

/// <param name="PN">原料PN码</param>

/// <returns>把表格返回</returns>

public static DataTable GetSelectPassOutAll(string PN)

{

DataTable dt = new DataTable();

SqlConnection conn = new SqlConnection(strconn);

SqlDataAdapter sda = new SqlDataAdapter("Pro_SelectAll", conn);

sdaSelectCommandCommandType = CommandTypeStoredProcedure;

sdaSelectCommandParametersAddWithValue("@PN", PN);

sdaFill(dt);

return dt;

}

#endregion

public static DataTable GetCategoryData(string Categroy, DateTime StartTime, DateTime EndTime)

{

DataTable dt = new DataTable();

SqlConnection conn = new SqlConnection(strconn);

SqlDataAdapter sda = new SqlDataAdapter("Pro_SelectAllCategroy", conn);

sdaSelectCommandCommandType = CommandTypeStoredProcedure;

sdaSelectCommandParametersAddWithValue("@Category", Categroy);

sdaSelectCommandParametersAddWithValue("@StartTime", StartTime);

sdaSelectCommandParametersAddWithValue("@EndTime", EndTime);

sdaFill(dt);

return dt;

}

/// <summary>

/// 进出汇总

/// </summary>

/// <param name="ST">开始时间</param>

/// <param name="ET">结束时间</param>

/// <returns></returns>

public static DataTable GetBomCount(DateTime ST, DateTime ET)

{

DataTable dt = new DataTable();

SqlConnection conn = new SqlConnection(strconn);

SqlDataAdapter sda = new SqlDataAdapter("Pro_BomCount", conn);

sdaSelectCommandCommandType = CommandTypeStoredProcedure;

sdaSelectCommandParametersAddWithValue("@StartTime", ST);

sdaSelectCommandParametersAddWithValue("@EndTime", ET);

sdaFill(dt);

return dt;

}

/// <summary>

/// 添加电池信息

/// </summary>

/// <returns></returns>

public static bool GetAddProduction(string JobID, string PN, string BomName, string BomCategroy, string Standard, string Dosage, string BomUnit, string Purpose, string Actor, string UR, DateTime Time)

{

bool result = false;

SqlConnection conn = new SqlConnection(strconn);

SqlCommand cmd = new SqlCommand("Pro_ADDProduction", conn);

cmdCommandType = CommandTypeStoredProcedure;

cmdParametersAddWithValue("@JobID", JobID);

cmdParametersAddWithValue("@PN", PN);

cmdParametersAddWithValue("@Bomname", BomName);

cmdParametersAddWithValue("@BomCategroy", BomCategroy);

cmdParametersAddWithValue("@Standard", Standard);

cmdParametersAddWithValue("@Dosage", Dosage);

cmdParametersAddWithValue("@BomUnit", BomUnit);

cmdParametersAddWithValue("@Purpose ", Purpose);

cmdParametersAddWithValue("@Actor ", Actor);

cmdParametersAddWithValue("@UR", UR);

cmdParametersAddWithValue("@Time", Time);

connOpen();

result = cmdExecuteNonQuery() > 0;

connDispose();

connClose();

return result;

}

/// <summary>

/// 显示所有产品信息

/// </summary>

/// <returns></returns>

public static DataTable GetShowProduction()

{

DataTable dt = new DataTable();

SqlConnection conn = new SqlConnection(strconn);

SqlDataAdapter sda = new SqlDataAdapter("Pro_ShowProduction", conn);

sdaSelectCommandCommandType = CommandTypeStoredProcedure;

sdaFill(dt);

return dt;

}

/// <summary>

/// 根据工单号查询电芯信息

/// </summary>

/// <param name="JID">工单号</param>

/// <returns></returns>

public static DataTable GetSelectProduct(string JID)

{

DataTable dt = new DataTable();

SqlConnection conn = new SqlConnection(strconn);

SqlDataAdapter sda = new SqlDataAdapter("Pro_CHK", conn);

sdaSelectCommandCommandType = CommandTypeStoredProcedure;

sdaSelectCommandParametersAddWithValue("@JobID", JID);

sdaFill(dt);

return dt;

}

/// <summary>

/// 显示添加的数据

/// </summary>

/// <returns></returns>

public static DataTable GetAllProduction()

{

DataTable dt = new DataTable();

SqlConnection conn = new SqlConnection(strconn);

SqlDataAdapter sda = new SqlDataAdapter("Pro_AllProduction", conn);

sdaSelectCommandCommandType = CommandTypeStoredProcedure;

sdaFill(dt);

return dt;

}

/// <summary>

/// 删除产品信息

/// </summary>

/// <param name="ID">删除条件ID</param>

/// <returns></returns>

public static bool GetDelProduction(int ID)

{

bool result = false;

SqlConnection conn = new SqlConnection(strconn);

SqlCommand cmd = new SqlCommand("Pro_DelProd", conn);

cmdCommandType = CommandTypeStoredProcedure;

cmdParametersAddWithValue("@ProductID", ID);

connOpen();

result = cmdExecuteNonQuery() > 0;

connDispose();

connClose();

return result;

}

public static DataTable GetSelectProductionJobID(string JobID, string PN, DateTime StartTime, DateTime EndTime)

{

DataTable dt = new DataTable();

SqlConnection conn = new SqlConnection(strconn);

SqlDataAdapter sda = new SqlDataAdapter("Pro_SelectProductionJobID", conn);

sdaSelectCommandCommandType = CommandTypeStoredProcedure;

sdaSelectCommandParametersAddWithValue("@JobID", JobID);

sdaSelectCommandParametersAddWithValue("@PN", PN);

sdaSelectCommandParametersAddWithValue("@StartTime", StartTime);

sdaSelectCommandParametersAddWithValue("@EndTime", EndTime);

sdaFill(dt);

return dt;

}

}

}

怎么在不同数据库之间进行同步数据

数据库A和数据库B是建立在两台独立的数据库服务器上,那么采用dblink方式是一种可行的方式,存在两个数据同步过程:

一、数据库A正常运行的时候需要将数据同步到备用库即数据库B;

二、数据库A不正常的时候启用数据库B,在数据库A恢复正常之前的数据更新都发生在数据库B,那么需要将数据库B的数据同步给数据库A。

第一种方式:前提是数据库A和数据库B本地网是24小时互通的同时对数据同步实时性有比较高的要求,那么可以建立DBLINK,在两个库都建触发器,不管当前在哪个库发生数据更新的时候实时同步数据到目标数据库;

1Powerscript语言里的事务处理对象怎么理解

程序与数据库之间传递信息的一个结构变量,共有15个成员你可以详细列表它的所有成员看看它的组成PB的应用程序会初始化一个全局的结构体变量,SQLCA,当然你也可以自定义一个自己的事务对象

1DBMSstring所使用的数据库管理系统的名字,如Sybase,Oracle,ODBC。

2Databasestring要连接的数据库名字。

3UserIDstring连接数据库所用的用户名。有的DBMS不需要此项。

4DBPassstring用户连接数据库的口令。

5Lockstring这是数据库的保护级别,一般不必给出。

6LogIDstring登录到数据库服务器上的用户名,有的DBMS不需要此项,但Sybase和Oracle需要指定这个参数。

7LogPassstring登录到数据库服务器上的用户口令。这个属性可设可不设,但Sybase和Oracle需要指定口令。

以上就是关于两个数据库之间如何互相调用数据全部的内容,包括:两个数据库之间如何互相调用数据、如何衡量数据库是否通信有力、两个数据库之间如何进行连接等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!

欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/sjk/9777602.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-05-01
下一篇 2023-05-01

发表评论

登录后才能评论

评论列表(0条)

保存