- 浏览: 23569 次
文章分类
- 全部博客 (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)
最新评论
private boolean ociSqlldr(String path, AbstractSqlLoad sqlload)
{
// 定义处理状态
boolean result = false;
try
{
sqlload.setDirectoryFile(getSqlLoadDirectory(), fileName,
getColumn(path));
// 设置用户名、密码、主机IP等参数
sqlload.setUseId(uName, passwd, getOraNetServerName());
// SQLLOAD 加载
result = sqlload.preform();
}
catch (Throwable e)
{
logger.error("Sqlload datafile " + this.fileName + " failed", e);
}
return result;
}
/**
* 使用调用oracle sqlldr工具的方式把数据入库。
* @param tableName 对应的数据库表名
* @param sqlldrFilePath sqlldr数据文件路径。
* @return 入库成功返回true,否则false
*/
private boolean oracleSqlldr(String tableName, String sqlldrFilePath,
AbstractSqlLoad sqlload)
{
// 定义处理状态
boolean result = false;
// 设置用户名、密码、主机IP等参数
sqlload.setUseId(uName, passwd, getOraNetServerName());
// 生成控制文件
GenOraCtrlFile writeCtl = new GenOraCtrlFile();
try
{
ctlFileName = (writeCtl.writeCtl(new File(getSqlLoadDirectory(),
fileName).getPath(), tableName)).getPath();
sqlload.setHome(DASProperties.getOracle_home());
sqlload.setCtlFile(ctlFileName);
// 获取日志文件名
/** SqlLoad日志文件名 */
String logFileName = configOracleLogFile();
// 设置要生成的log日志文件
sqlload.setLogFile(logFileName);
// 设置要生成的bad文件
sqlload.setBadFile(configOracleBadFile());
if (db.equalsIgnoreCase(SCHEMA_DPI_RPT))
{
// 实时流量 设置Direct=false
sqlload.setDirect(false);
}
else
{
// 默认设置Direct=true
sqlload.setDirect(true);
}
// SQLLOAD 加载
result = sqlload.preform();
// 如果数据文件入库失败,把sqlLoad的日志文件写到DAS日志文件中
if (!result)
{
this.readSqlLoadErrLog(logFileName);
}
/** 删除SqlLoad日志文件 */
if (isNeedDelLogFile())
{
File logFile = new File(logFileName);
if (!FileUtil.delete(logFile))
{
logger.error("delete log file failed! the file name is "
+ logFile.getName());
}
}
// 判断load子进程是否挂死或超时
if (sqlload.isTimeOut())
{
throw new IllegalThreadStateException(
"The oracle sqlldr prcess is not determined!");
}
}
catch (Throwable e)
{
logger.error("Sqlload datafile " + this.fileName + " failed", e);
}
return result;
}
{
// 定义处理状态
boolean result = false;
try
{
sqlload.setDirectoryFile(getSqlLoadDirectory(), fileName,
getColumn(path));
// 设置用户名、密码、主机IP等参数
sqlload.setUseId(uName, passwd, getOraNetServerName());
// SQLLOAD 加载
result = sqlload.preform();
}
catch (Throwable e)
{
logger.error("Sqlload datafile " + this.fileName + " failed", e);
}
return result;
}
/**
* 使用调用oracle sqlldr工具的方式把数据入库。
* @param tableName 对应的数据库表名
* @param sqlldrFilePath sqlldr数据文件路径。
* @return 入库成功返回true,否则false
*/
private boolean oracleSqlldr(String tableName, String sqlldrFilePath,
AbstractSqlLoad sqlload)
{
// 定义处理状态
boolean result = false;
// 设置用户名、密码、主机IP等参数
sqlload.setUseId(uName, passwd, getOraNetServerName());
// 生成控制文件
GenOraCtrlFile writeCtl = new GenOraCtrlFile();
try
{
ctlFileName = (writeCtl.writeCtl(new File(getSqlLoadDirectory(),
fileName).getPath(), tableName)).getPath();
sqlload.setHome(DASProperties.getOracle_home());
sqlload.setCtlFile(ctlFileName);
// 获取日志文件名
/** SqlLoad日志文件名 */
String logFileName = configOracleLogFile();
// 设置要生成的log日志文件
sqlload.setLogFile(logFileName);
// 设置要生成的bad文件
sqlload.setBadFile(configOracleBadFile());
if (db.equalsIgnoreCase(SCHEMA_DPI_RPT))
{
// 实时流量 设置Direct=false
sqlload.setDirect(false);
}
else
{
// 默认设置Direct=true
sqlload.setDirect(true);
}
// SQLLOAD 加载
result = sqlload.preform();
// 如果数据文件入库失败,把sqlLoad的日志文件写到DAS日志文件中
if (!result)
{
this.readSqlLoadErrLog(logFileName);
}
/** 删除SqlLoad日志文件 */
if (isNeedDelLogFile())
{
File logFile = new File(logFileName);
if (!FileUtil.delete(logFile))
{
logger.error("delete log file failed! the file name is "
+ logFile.getName());
}
}
// 判断load子进程是否挂死或超时
if (sqlload.isTimeOut())
{
throw new IllegalThreadStateException(
"The oracle sqlldr prcess is not determined!");
}
}
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数据库
(3)MS SQL Server 2000安装/MSDE2000/MS SQL Server 2005 /MS SQL Server 2008 (4) IE需要升级到6.0以上。 (仅对Windows 2000的各个版本) 2.Windows server 2003/2008 (1)IIS安装 (2)MS SQL Server ...
IGT-DSER智能网关模块,支持各种PLC、智能仪表、远程IO与数据库之间双向通讯,既可以读取设备的数据上报到SQL数据库,也可以从数据库查询数据后写入到设备;数据库软件支持MySQL、SQLSwever、PostgreSQL。 网关安装...
3、数据统计:包括免疫样品数 免疫样品合格数 免疫样品合格率等统计,可扩展自己的数据。 4、控制面板:模块管理、单位信息、角色信息、用户信息。 5、个人管理:修改密码。 三、注意事项 2、开发环境为Visual...
项目中有两台S7-1500的PLC,需要将其数据通过一个智能网关采集到MySQL数据库;网关采集多台智能仪表数据到... 最后配置数据库参数和PLC数据寄存器地址,通过参数软件的功能视图->数据上报与查询,切换到如下画面:
本程序用于自动导出数据上报流感监测信息。需要的同学可下载学习。使用VS2017编译。 通过文件操作,加载SQL文件夹下特定语句和变量条件,查询数据库结果后保存为 文件名yyyymmdd.csv格式文件。 Console.WriteLine...
基于MQTT开发数据采集,支持N个订阅N个发布,经过严格测试,支持上万连接同时订阅和发布信息,采用C#开发数据采集, 建议,可以使用此系统做数据采集,Java做前端展示,目前数据库支持sqlserver
EA2A还可以作为数据上报时的导入工具,比如下级机关对上级机关上报数据(可上报Excel/Access格式)。 EA2A支持Access数据库表与表、视图与视图之间数据的互导。 EA2A可做为简单的SQL查询分析器使用,如果打开方式为...
教学资料上报系统数据库设计 1、实训报告书; 2、数据库数据表实现的SQL语句; 3、备份的数据库文件。 1、完成“任课教师”角色内容设计; 2、完成“教研室主任”、“系部督导员”、“管理员”角色内容设计共)...
1.本软件为试用版,仅上传的示例数据,不接受服务端数据设定 2.正式版连接Sql Server数据库,可按要求上报光伏电站即时运行数据,可以随时接受服务端指令,按服务端要求上传历史数据,按服务端要求配置相关参数
故障上报管理页面,此页面提供给管理员的功能有:根据故障上报进行条件查询,还可以对故障上报进行新增、修改、查询操作等等。论坛信息管理页面,此页面提供给管理员的功能有:根据论坛信息进行新增、修改、查询操作...
其次,对赋予集团仓储物流序列号的物料进行上下架处理,登记相对应的上下架信息,同步到集团的SQL server数据库中锁定数据,以免数据流失;最后,若有出现程序异常报错现象,相关人员可手动填写程序报错日志,并同步...
最近时间刚从客户端转入后台写服务,对于后台数据库以及服务的书写完全是个小白,所以最近写的肯定没有太多技术含量。 首先把遇到的问题摆... 看到问题首先想到的是要group by ReportPerson,能将每个人的统计数据计
4、数据集成 各系部的局部数据在录入后,要及时上报,在全局数据库进行汇总。各部门的数据有更 新变动时,也要及时上报在全局数据库同步更新。再由全局数据库分发给与数据信息有 关的相关部门。如某系学生人数的...
上报数据为DBISAM格式,数据密码:32832041,不要尝试研究上报数据内容,因为很难看懂字段的含义,你可以根据需要自己去改。 11、注意:dbisam版本为:3.24的。 12、重新编译完毕后注意使用ASPACK.EXE压缩一下...