- 浏览: 23598 次
文章分类
- 全部博客 (35)
- linux (0)
- basedaoimpl 1 (0)
- basedao (1)
- basedaoimpl 2 (0)
- basedaoimpl 3 (0)
- basedaoimpl 4 (0)
- basedaoimpl 5 (0)
- basedaoimpl 6 (0)
- basedaoimpl 7 (0)
- htmlservlet1 (0)
- htmlservlet2 (0)
- htmlservlet3 (0)
- htmlservlet4 (0)
- excle1 (0)
- excle2 (0)
- pdf1 (0)
- pdf2 (0)
- servletutil1 (0)
- servletutil2 (0)
- servletutil3 (0)
- ziputil1 (0)
- ziputil2 (0)
- 项目管理以及统计工具 (0)
- linux命令总结 (0)
- 经典回答 (0)
- TR点设置 (0)
- TR点设置2 (0)
- 枚举 (1)
- tomcat5.5.xx以上 (1)
- 标准的写法遍历Map (1)
- 线程安全 (1)
- sql (1)
- 转义字符 (1)
- 经典美文1 (1)
- 经典美文2 (1)
- 经典美文3 (1)
- webservice以及线程应用 (1)
- webservice以及线程应用2 (1)
- InitializingBean应用 (1)
- 线程应用 (1)
- sqlloader1 (1)
- sqlloader2 (1)
- sqlloader3 (1)
- sqlloader4 (1)
- sqlloader5 (1)
- sqlloader6 (1)
- sqlloader7 (1)
- sql上报数据1 (1)
- sql上报数据2 (1)
- sql上报数据3 (1)
- sql上报数据4 (1)
- sql上报数据5 (1)
- sql上报数据6 (1)
- iputil1 (1)
- iputil2 (1)
- iputil3 (1)
- oracle sql1 (1)
- oracle sql2 (1)
- 线程池1 (0)
- 线程池3 (0)
- 日期处理1 (0)
- 日期处理2 (0)
- 日期处理3 (0)
- 日期处理4 (0)
- iputil4 (0)
- iputil5 (0)
- iputil6 (0)
- 日期处理6 (0)
- 日期处理7 (0)
- 日期处理8 (0)
- protocolList (0)
- DATELONG2TEXT (0)
- Dateinfo5 (0)
- Dateinfo6 (0)
- Dateinfo7 (0)
- Dateinfo8 (0)
- Dateinfo9 (0)
- Dateinfo10 (0)
- Dateinfo11 (0)
- Dateinfo12 (0)
- 处理ifream滚动条 (0)
- 工具面试题 (0)
- oracle1 (0)
- 批量插入数据 (0)
- oracle2 (0)
- oracle3 (0)
- oracle4 (0)
- oracle5 (0)
- oracle6 (0)
- oracle7 (0)
- oracle8 (0)
- oracle9 (0)
- oracle11 (0)
- oracle12 (0)
- oracle13 (0)
- oracle14 (0)
- oracle15 (0)
- http://zhang-xzhi-xjtu.iteye.com/category/133743 (1)
- 绑定变量 (0)
- 绑定变量2 (0)
- 绑定变量3 (0)
- 合理使用排序 (0)
- Jconsole 内存1 (0)
- Jconsole 内存2 (0)
- Jconsole 内存3 (0)
- io nio (0)
- nio (0)
- Batch (0)
- fetchsize (0)
- fetchsize2 (0)
- 面试题 (0)
- ExecutorService线程池 (0)
- 阻塞队列 (0)
- 简单阻塞队列实现 (0)
- 简单阻塞队列实现2 (1)
- CountDownLatch 结合线程应用 (0)
- 线程池 (0)
- 阻塞队列2 (0)
- LockSupport park unpark interrupt notifyAll wait等关系区别 (0)
- LockSupport park unpark interrupt notifyAll wait等关系区别1 (0)
- LockSupport park unpark interrupt notifyAll wait等关系区别2 (0)
- nio FileChannel (1)
- Nio Charset (0)
- nio 学习 (0)
- 杨化龙 (0)
- 排序1 (0)
- 排序2 (0)
- tomcat内存配置 (0)
- 字符串转换16进制数表示的字符串 (0)
- Dpi.report.common.TopnEdit (0)
- Dpi.report.common.TopnEdit2 (0)
- Dpi.report.common.TopnEdit3 (0)
- Dpi.report.common.TopnEdit4 (0)
- webservice调用 (0)
最新评论
/**
* 初始化入库文件的数据库相关信息
* @param fileName
* @param dbInfo
*/
public SqlLoad(String fileName, DBInfo dbInfo, String loadDirectory)
{
this.fileName = fileName;
// 配置数据库相关信息
dbType = dbInfo.getDbType();
host = DasUtil.longToIP(dbInfo.getIp());
db = dbInfo.getSchema();
uName = dbInfo.getUserName();
passwd = dbInfo.getPassword();
// 生成的load文件目录
sqlLoadDirectory = loadDirectory;
}
/**
* 上报数据
*
* @return
*/
public boolean sqlldr(AbstractSqlLoad oracleSqlload)
{
// 定义处理状态
boolean result = false;
// 如果dbType是RptConstants.DB_TYPE_MYSQL ,数据库类型是MySQL
if (dbType == DasConstants.DB_TYPE_MYSQL)
{
MySQLSqlLoad sqlload = new MySQLSqlLoad();
// 设置相关参数
sqlload.setDataBase(db);
sqlload.setHost(host);
sqlload.setPassword(passwd);
sqlload.setUser(uName);
sqlload.setHome(DASProperties.getMysql_home());
try
{
sqlload.setFilenameAndTable(getSqlLoadDirectory(), fileName,
fileName.substring(fileName.indexOf("_") + 1, fileName
.lastIndexOf(".")));
}
catch (IOException e)
{
logger.error(e.getMessage(), e);
}
// SQLLOAD 加载
try
{
result = sqlload.preform();
}
catch (Throwable e)
{
logger.error("Mysql sqlload datafile failed.", e);
}
// 判断load子进程是否挂死或超时
if (sqlload.isTimeOut())
{
throw new IllegalThreadStateException(
"The mysql sqlldr prcess is not determined!");
}
}
// 如果dbType是RptConstants.DB_TYPE_ORACLE,数据库类型是ORACLE
else if (dbType == DasConstants.DB_TYPE_ORACLE)
{
try
{
String tabName = fileName.substring(fileName.indexOf("_") + 1,
fileName.lastIndexOf(DasConstants.TXT_FIILE_SUFFIX));
String path = new File(getSqlLoadDirectory(), fileName)
.getPath();
// 在linux服务器下使用oracle oci实现的jni sqlldr。
if (oracleSqlload.isLinux())
{
result = ociSqlldr(path, oracleSqlload);
}
// 其它操作系统使用oracle sqlldr工具进行load数据。
else
{
result = oracleSqlldr(tabName, path, oracleSqlload);
}
}
catch (Throwable e)
{
logger
.error("Sqlload datafile " + this.fileName + " failed",
e);
}
}
/* 返回处理状态 */
return result;
}
* 初始化入库文件的数据库相关信息
* @param fileName
* @param dbInfo
*/
public SqlLoad(String fileName, DBInfo dbInfo, String loadDirectory)
{
this.fileName = fileName;
// 配置数据库相关信息
dbType = dbInfo.getDbType();
host = DasUtil.longToIP(dbInfo.getIp());
db = dbInfo.getSchema();
uName = dbInfo.getUserName();
passwd = dbInfo.getPassword();
// 生成的load文件目录
sqlLoadDirectory = loadDirectory;
}
/**
* 上报数据
*
* @return
*/
public boolean sqlldr(AbstractSqlLoad oracleSqlload)
{
// 定义处理状态
boolean result = false;
// 如果dbType是RptConstants.DB_TYPE_MYSQL ,数据库类型是MySQL
if (dbType == DasConstants.DB_TYPE_MYSQL)
{
MySQLSqlLoad sqlload = new MySQLSqlLoad();
// 设置相关参数
sqlload.setDataBase(db);
sqlload.setHost(host);
sqlload.setPassword(passwd);
sqlload.setUser(uName);
sqlload.setHome(DASProperties.getMysql_home());
try
{
sqlload.setFilenameAndTable(getSqlLoadDirectory(), fileName,
fileName.substring(fileName.indexOf("_") + 1, fileName
.lastIndexOf(".")));
}
catch (IOException e)
{
logger.error(e.getMessage(), e);
}
// SQLLOAD 加载
try
{
result = sqlload.preform();
}
catch (Throwable e)
{
logger.error("Mysql sqlload datafile failed.", e);
}
// 判断load子进程是否挂死或超时
if (sqlload.isTimeOut())
{
throw new IllegalThreadStateException(
"The mysql sqlldr prcess is not determined!");
}
}
// 如果dbType是RptConstants.DB_TYPE_ORACLE,数据库类型是ORACLE
else if (dbType == DasConstants.DB_TYPE_ORACLE)
{
try
{
String tabName = fileName.substring(fileName.indexOf("_") + 1,
fileName.lastIndexOf(DasConstants.TXT_FIILE_SUFFIX));
String path = new File(getSqlLoadDirectory(), fileName)
.getPath();
// 在linux服务器下使用oracle oci实现的jni sqlldr。
if (oracleSqlload.isLinux())
{
result = ociSqlldr(path, oracleSqlload);
}
// 其它操作系统使用oracle sqlldr工具进行load数据。
else
{
result = oracleSqlldr(tabName, path, oracleSqlload);
}
}
catch (Throwable e)
{
logger
.error("Sqlload datafile " + this.fileName + " failed",
e);
}
}
/* 返回处理状态 */
return result;
}
相关推荐
2_甘肃数据上报初始化.sql
SQL Server数据库远程数据上报策略及应用研究.pdf
自定义数据上报接口顾名思义就是个人可以根据数据上报接口要求书写Sql语句或创建视图植入软件内并自动生成所需的文件进行上报。作者根据多年医疗数据上报接口的开发经验创作了此款以Oracle数据库为主的简单实用的...
SQL查询在高校就业签约数据上报中的应用.pdf
IGT-SER系列智能网关模块,支持各种PLC、智能仪表、远程IO与数据库之间双向通讯,既可以读取设备的数据上报到SQL数据库,也可以从数据库查询数据后写入到设备;数据库软件支持MySQL、SQLServer、PostgreSQL。 IGT-...
How to connect a Siemens S7 1200 PLC to a SQL Server Database Siemens S7 1200 PLC连接SQLSERVER数据库
(2)MS SQL Server 2000安装/MSDE2000/MS SQL Server 2005/MS SQL Server 2008 3.运行环境 [返回页首] 3.0 安装Excel报表上报&统计系统 要安装Excel报表上报&统计系统,请按照以下各节中的说明执行。 3.1 ...
IGT-DSER智能网关模块,支持各种PLC、智能仪表、远程IO与数据库之间双向通讯,既可以读取设备的数据上报到SQL数据库,也可以从数据库查询数据后写入到设备;数据库软件支持MySQL、SQLSwever、PostgreSQL。 网关安装...
这是一款比较集动物疾病上报、监 测、预警、信息查询、数据统计、分析、应用、辅助决策 、 疫情应急调度指挥GIS系统,系统需要ArcgisServer9支持,系统写好各种专题图... 2、开发环境为Visual Studio 2008 SQL 2005
项目中有两台S7-1500的PLC,需要将其数据通过一个智能网关采集到MySQL数据库;网关采集多台智能仪表数据到... 最后配置数据库参数和PLC数据寄存器地址,通过参数软件的功能视图->数据上报与查询,切换到如下画面:
EA2A还可以作为数据上报时的导入工具,比如下级机关对上级机关上报数据(可上报Excel/Access格式)。 EA2A支持Access数据库表与表、视图与视图之间数据的互导。 EA2A可做为简单的SQL查询分析器使用,如果打开方式为...
基于MQTT开发数据采集,支持N个订阅N个发布,经过严格测试,支持上万连接同时订阅和发布信息,采用C#开发数据采集, 建议,可以使用此系统做数据采集,Java做前端展示,目前数据库支持sqlserver
本程序用于自动导出数据上报流感监测信息。需要的同学可下载学习。使用VS2017编译。 通过文件操作,加载SQL文件夹下特定语句和变量条件,查询数据库结果后保存为 文件名yyyymmdd.csv格式文件。 Console.WriteLine...
2、数据库数据表实现的SQL语句; 3、备份的数据库文件。 1、完成“任课教师”角色内容设计; 2、完成“教研室主任”、“系部督导员”、“管理员”角色内容设计共); 3、实训报告书; 4、数据库数据表实现的SQL...
1.本软件为试用版,仅上传的示例数据,不接受服务端数据设定 2.正式版连接Sql Server数据库,可按要求上报光伏电站即时运行数据,可以随时接受服务端指令,按服务端要求上传历史数据,按服务端要求配置相关参数
故障上报管理页面,此页面提供给管理员的功能有:根据故障上报进行条件查询,还可以对故障上报进行新增、修改、查询操作等等。论坛信息管理页面,此页面提供给管理员的功能有:根据论坛信息进行新增、修改、查询操作...
endTime)每个人每天上报的错误个数(2)统计一定时间内【起止时间到精确到月】(beginTime,endTime)按月统计每个人上报的错误总数。 看到问题首先想到的是要group by ReportPerson,能将每个人的统计数据计
其次,对赋予集团仓储物流序列号的物料进行上下架处理,登记相对应的上下架信息,同步到集团的SQL server数据库中锁定数据,以免数据流失;最后,若有出现程序异常报错现象,相关人员可手动填写程序报错日志,并同步...
上报数据为DBISAM格式,数据密码:32832041,不要尝试研究上报数据内容,因为很难看懂字段的含义,你可以根据需要自己去改。 11、注意:dbisam版本为:3.24的。 12、重新编译完毕后注意使用ASPACK.EXE压缩一下...
2、数据的分布 从全局应用的角度出发,将局部数据库自下而上构成分布式数据库系统,各系部存放本 机构的数据,全局数据库则存放所有业务数据,并对数据进行完整性和一致性的检查, 这种做法虽然有一定的数据冗余,...