首页 > 数据库 >openPlant实时数据库使用demo

openPlant实时数据库使用demo

时间:2023-12-20 23:03:05浏览次数:35  
标签:jdbc String openPlant int demo 数据库 System sql conn

相关依赖

由于没有com.magus.jdbc.jar依赖,需要手动下载防止lib下进行配置

<dependency>
	<groupId>com.magus</groupId>
	<artifactId>jdbc</artifactId>
	<version>3.0</version>
	<scope>system</scope>
	<systemPath>${basedir}/lib/com.magus.jdbc.jar</systemPath>
</dependency>

测试连接demo

public static void main(String[] args) {
  try {
  	OPConnect conn = new OPConnect("192.168.2.127", 8300, 60, "sis", "openplant");
  	System.out.println(conn.getServerTime());
  } catch (UsersException e) {
  	e.printStackTrace();
  } catch (IOException e) {
  	e.printStackTrace();
  }
	}

测试查询

public static void main(String[] args) throws InterruptedException,OPException {
		try {
			Class.forName(className);
			Connection conn = DriverManager.getConnection(url, user, password);
			int count = 50000;
			String sql = "select GN from Point limit 0," + count;
			System.out.println("sql:" + sql);

			Statement st = conn.createStatement();
			// for (int i = 0; i < 10; i++) {
			long s = System.currentTimeMillis();
			ResultSet rs = st.executeQuery(sql);
			ResultSetMetaData rsmd = rs.getMetaData();
			for (int i = 1; i <= rsmd.getColumnCount(); i++) {
				System.err.print(rsmd.getColumnLabel(i).toUpperCase() + "\n");
			}
			int t = 0;
			String[] GNs = new String[count];
			while (rs.next()) {
				GNs[t] = "'" + rs.getString(1) + "'";
				t++;
			}
			System.out.println("all count:" + t);
			String gns = "";
			for (int i = 0; i < t; i++) {
				gns += GNs[i];
				if (i < (t - 1)) {
					gns += ",";
				}
			}
			rs.close();
			long e = System.currentTimeMillis();
			System.out.println("用时:" + (e - s));

			sql = "select ID,GN from Point where GN in (" + gns + ")";
			rs = st.executeQuery(sql);
			rsmd = rs.getMetaData();
			for (int i = 1; i <= rsmd.getColumnCount(); i++) {
				System.err.print(rsmd.getColumnLabel(i).toUpperCase() + "\t");
			}
			int i = 0;
			System.err.println("\n");
			while (rs.next()) {
				i++;
				System.err.println(rs.getInt(1) + "\t" + rs.getString(2));
			}
			System.err.println("all count:" + i);
			System.out.println("遍历耗时:" + (System.currentTimeMillis() - e));
			rs.close();
			st.close();

		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (SecurityException e) {
			OPException ex = new OPException("程序包空间不能与提供的JAR包空间一致");
			throw ex;
		}

标签:jdbc,String,openPlant,int,demo,数据库,System,sql,conn
From: https://blog.51cto.com/u_15266301/8911336

相关文章

  • StarRocks2.3 MPP数据库安装
    1. 规划FEBE10.11.14.1510.11.14.13、10.11.14.15、10.11.14.162.安装记录2.1已安装已完成 10.11.14.15、10.11.14.16两台机器相应节点的安装。10.11.14.1510.11.14.16下面完成 10.11.14.13机器BE节点的安装。参考:https://docs.starrocks.io/zh-cn/2.3/quick_start/Deploy......
  • des加密,url编码,url解码,des解密 DEMO
    des加密,url编码,url解码,des解密DEMOpackagecom.example.core.mydemo.des;importjavax.crypto.Cipher;importjavax.crypto.SecretKey;importjavax.crypto.SecretKeyFactory;importjavax.crypto.spec.DESKeySpec;importjava.net.URLDecoder;importjava.net.URLEncod......
  • openGauss学习笔记-166 openGauss 数据库运维-备份与恢复-导入数据-使用COPY FROM STD
    openGauss学习笔记-166openGauss数据库运维-备份与恢复-导入数据-使用COPYFROMSTDIN导入数据-从MY向openGauss数据库进行数据迁移166.1示例2:从MY向openGauss数据库进行数据迁移下面示例演示如何通过CopyManager从MY向openGauss数据库进行数据迁移的过程。importjava.io.St......
  • openGauss学习笔记-167 openGauss 数据库运维-备份与恢复-导入数据-使用gsql元命令导
    openGauss学习笔记-167openGauss数据库运维-备份与恢复-导入数据-使用gsql元命令导入数据gsql工具提供了元命令\copy进行数据导入。167.1\copy命令\copy命令格式以及说明参见表1\copy元命令说明。表1\copy元命令说明语法说明\copy{table[(column_list)......
  • c203数据库练习题下半
    2、视图练习(1)建立视图v_xs_1,要求包含男生的学号,姓名,性别,出生日期,班级编号,专业名称字段,并要求视图操作数据时进行检查。使用select命令查询创建的视图。createviewv_xs_1asselectxh,xm,xb,csrq,bjbh,zymcfromxsjbxxbwherexb='男'withcheckoption;建立一个学院教师......
  • c203数据库练习题上半
    1.使用SQL语言创建满足以下要求的数据库。(1)创建数据库名称为jwgl,字符集选择utf8,排序规则选择utf8_general_ci。createdatabasejwglcharactersetutf8collateutf8_general_ci;(2)查看数据库。showdatabases;(3)将数据库jwgl的指定字符集修改为gb2312。mysql>alterdatabasejwg......
  • 关于数据库的基础
    单一索引:只是用某一列数据作为索引,默认是index索引,这一列可以包含重复数据;如果某一列不存在重复数据最好设置成unique形式的索引,比index的索引速度更快,在text数据上要使用fulltext索引。联合索引:为了更进一步提高检索速度,每次检索都需要用多列同时进行时,就可以把这多列设为联合索......
  • 数据库备份与恢复
    在任何数据库环境中,总会有不确定的意外情况发生,比如例外的停电、计算机系统中的各种软硬件故障、人为破坏、管理员误操作等是不可避免的,这些情况可能会导致数据的丢失、服务器瘫痪等严重的后果。存在多个服务器时,会出现主从服务器之间的数据同步问题。为了有效防止数据丢失,并......
  • 达梦数据库V8 命令行静默安装
    unzipdm8_20230420_x86_kylin10_64.zipmount-oloop-tiso9660dm8_20230420_x86_kylin10_64.iso/mnt/ulimit-HSn65535groupadddinstalluseradd-gdinstall-m-d/home/dmdba-s/bin/bashdmdbapasswddmdbamkdir/data/dm8chown-Rdmdba:dinstall/......
  • 数据库软硬件选型的思考
    数据库软硬件选型的思考背景最近有多个项目出现过数据库的问题这里想总结语一下遇到的问题.以及可能的软硬件优化方案与思路.暂时还没有进行过系统的测试验证,所以仅是一个思考,后续会慢慢完善.硬件选型截止现在2024年元旦之前.Oracle数据库我认为还是选择Inte......