Sybase TDS协议分析

2023-11-04 10:40
文章标签 分析 协议 sybase tds

本文主要是介绍Sybase TDS协议分析，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

2019独角兽企业重金招聘Python工程师标准>>> hot3.png

TDS版本比较老，可能与当前版本有所不同。

Sybase与Sql Server部份版本 都采用TDS协议，但包大小等有所不同。


import java.util.LinkedList;/*** TDS协议分析适用于Sybase<br/>* TDS版本4.2应用Sybase SQL Server < 10 and Microsoft SQL Server 6.5<br/>* TDS版本5.0应用于Sybase SQL Server >= 10* @author shanl**/
public class TDSAnalyForSybase implements SybaseTDSType{private LinkedList<byte[]> packageBuffer = new LinkedList<byte[]>();/*** 向缓存区插入一个数据包* @param bys* @param offset* @param len* @return true:最后一个包,false:非最后一个数据包*/public boolean addPackage(byte[] bys, int offset, int len){byte[] tmp = new byte[len];int lastFlag = bys[1];System.arraycopy(bys, offset, tmp, 0, len);this.packageBuffer.addLast(tmp);return LAST_INDICATOR_LAST_PACKETS==lastFlag;}/*** 得到并从队列中移除最后一个数据包* @return*/public byte[] pollPackage(){return this.packageBuffer.pollFirst();}/*** 取(并移除)最后一个数据包* @param bys* @param offset* @return*/public int getFirstPackage(byte[] bys, int offset){byte[] tmp = pollPackage();System.arraycopy(tmp, 0, bys, offset, tmp.length);return tmp.length;}//		//头8个字节为标志
//		int packageType = bys[offset+0]; 	//0x0f表示TDS5.0 query; 0x02表示TDS 4.2 & 5.0 Login Packet
//		int lastFlag = bys[offset+1];		//最后一个包标志,0x00表示还有更多包,0x01表示是最后一个包
//		int packageSize = Utility.byte2Short(bys, offset+2);	//包他长度
//		byte space0 = bys[offset+4];		//以下4(从当前位置算起)个为0x00
//		byte space1 = bys[offset+5];
//		byte space2 = bys[offset+6];
//		byte space3 = bys[offset+7];		
//		//内容
//		byte flag0 = bys[offset+8]; 	//0x21 
//		byte flag1 = bys[offset+9]; 	//0x00
//		byte flag2 = bys[offset+10]; 	//0x00				
//		int sqlLen = Utility.byte2Short(bys, offset+11);	//sql长度
//				
//		byte[] flag = new byte[3];		
//		int packageCount = 0;
//	/**
//	 * 返回sql<br/>
//	 * 建议在测试isLastPackage()后，再执行此语句，否则你拿到的sql可能是不完整的。
//	 * @return 如果数据不完整或没有sql则返回""
//	 */
//	public String getString(){
//		String sql = "";	
//		int packageSize = 0;byte[] bys = null;
//		for(int i=0,end=size(); i<end; i++){
//		for(byte[] bys: packageBuffer){
//			packageSize = Utility.byte2Short(bys, 2);
//			
//			//字节过于少的数据包将被抛弃
//			if(packageSize>=9){
//				if(0x21==bys[8] && 0x00==bys[9] && 0x00==bys[10]){
//					sql += new String(bys, 4+4+3+2, packageSize-(4+4+3+2));}else if(0x01 == bys[1]){sql += new String(bys, 4+4, packageSize-(4+4));break;
//				}else if(0xE6==bys[8] && 0x00==bys[9] && 0x09==bys[10]){
//				}else{
//					sql += new String(bys, 4+4, packageSize-(4+4));
//				}				
//				
//				bys = null;
//			}			
//		}
//		
//		return sql;
//	}/*** 返回sql语句* @return*/public String getSql(){String sql = "";	int packageSize = 0;byte[] bys = null;boolean flagSql = false;int sysbaseHeaderSize = 4+4+4+2;for(int i=0,end=size(); i<end; i++){
//		for(byte[] bys: packageBuffer){bys = this.packageBuffer.get(i);packageSize = Utility.byte2Short(bys, 2);if(packageSize>=9){if(0x0f!=bys[0]){	//连接请求					break;}//				if(0xe6==bys[8] && 0x00==bys[9] && 0x09==bys[10]){	//不符合sql语句规范
//					break;
//				}if(flagSql){sql += new String(bys, 4+4, packageSize-(4+4));continue;}if(0x21==bys[8] ){	//符合sql语句规范 //&& 0x00==bys[9] && 0x00==bys[10]		sql += new String(bys, sysbaseHeaderSize, packageSize-(sysbaseHeaderSize));flagSql = true;}else{	//不符合sql语句规范break;}				}}		reset();return sql;}/*** 返回缓存区的数据包数* @return*/public int size(){return this.packageBuffer.size();}/*** 缓存区是否为空* @return*/public boolean isEmpty(){return this.packageBuffer.isEmpty();}/*** 重置数据<br/>* 调用此方法用清空旧数据*/public void reset(){this.packageBuffer.clear();}/*** 返回最后一次插入的包类型* @return 	0x0f表示TDS5.0 query;<br/> * 			0x02表示TDS 4.2 & 5.0 Login Packet*/public int getPackageType(){int packageType = packageBuffer.getLast()[0];; 	//0x0f表示TDS5.0 query; 0x02表示TDS 4.2 & 5.0 Login Packetreturn packageType;}//	/**
//	 * 返回最后一次插入的包是否为SQL的最后一个包
//	 * @return 	0:最后一个sql数据包 <br/>
//	 * 			1:非最后一个sql数据包 <br/>
//	 * 			2:非sql数据包 
//	 */
//	public int isSqlLastPackage(){
//		byte[] bys = packageBuffer.getLast();
//		int lastFlag = bys[1];		//最后一个包标志,0x00表示还有更多包,0x01表示是最后一个包
//		int res = 2;
//		
//		if(LAST_INDICATOR_LAST_PACKETS==lastFlag){
//			if(0x21==bys[8] && 0x00==bys[9] && 0x00==bys[10]){ 			//sql标志
//				res = 1;
//			}else if(0xE6==bys[8] && 0x00==bys[9] && 0x09==bys[10]){ 	//非sql标志
//				res = 2;
//			}else{
//				res = 0;
//			}
//		}else{
//			res = 2;
//		}
//		
//		return res;
//	}/*** 返回最后一次插入的包长度* @return 长度>=0*/public int getPackageLength(){return Utility.byte2Short(packageBuffer.getLast(), 2);	}
}

/*** 定义SyBase TDS的各种类型<br/>* TDS版本:4.2/5.0<br/>* 格式:<br/>* INT8, INT8, INT16, 4 bytes <br/>* packet type, last packet indicator, 	packet size,unknown(always 0x00)* @author shanl**/
public interface SybaseTDSType {/**0x01 TDS 4.2 or 7.0 query*/byte PACKAGE_TYPE_QUERY_V42_OR_V70 = 0x01;	/**0x02 TDS 4.2 or 5.0 login packet*/byte PACKAGE_TYPE_LOGIN_V42_OR_V50 = 0x02;/** 0x03 RPC*/byte PACKAGE_TYPE_RPC = 0x03;/**0x04 responses from server*/byte PACKAGE_TYPE_RESPONSES_FROM_SERVER = 0x04;/**0x06 cancels*/byte PACKAGE_TYPE_CANCELS = 0x06;/**0x07 Used in Bulk Copy*/byte PACKAGE_TYPE_USERD_IN_BULK_COPY = 0x07;/**0x0F TDS 5.0 query*/byte PACKAGE_TYPE_QUERY_V50 = 0x0f;/**0x10 TDS 7.0 login packet*/byte PACKAGE_TYPE_LOGIN = 0x10;/***0x11 TDS 7.0 authentication packet*/byte PACKAGE_TYPE_AUTH = 0x11;/**0x12 TDS 8 prelogin packet*/byte PACKAGE_TYPE_PRELOGIN = 0x12;/**0x00 if more packets*/byte LAST_INDICATOR_MORE_PACKETS = 0x00;/**0x01 if last packet*/byte LAST_INDICATOR_LAST_PACKETS = 0x01;
}

package codedepot.hkproject.net.ACSA.db.sybase.util;/*** 各基础类型与byte之间的转换* @author shanl**/
public class Utility {/*** 将short转成byte[2]* @param a* @return*/public static byte[] short2Byte(short a){byte[] b = new byte[2];b[0] = (byte) (a >> 8);b[1] = (byte) (a);return b;}/*** 将short转成byte[2]* @param a* @param b* @param offset b中的偏移量*/public static void short2Byte(short a, byte[] b, int offset){b[offset] = (byte) (a >> 8);b[offset+1] = (byte) (a);}/*** 将byte[2]转换成short* @param b* @return*/public static short byte2Short(byte[] b){return (short) (((b[0] & 0xff) << 8) | (b[1] & 0xff));}/*** 将byte[2]转换成short* @param b* @param offset* @return */public static short byte2Short(byte[] b, int offset){return (short) (((b[offset] & 0xff) << 8) | (b[offset+1] & 0xff));}/*** long转byte[8]* * @param a* @param b* @param offset*            b的偏移量*/public static void long2Byte(long a, byte[] b, int offset) {		b[offset + 0] = (byte) (a >> 56);b[offset + 1] = (byte) (a >> 48);b[offset + 2] = (byte) (a >> 40);b[offset + 3] = (byte) (a >> 32);b[offset + 4] = (byte) (a >> 24);b[offset + 5] = (byte) (a >> 16);b[offset + 6] = (byte) (a >> 8);b[offset + 7] = (byte) (a);}/*** byte[8]转long* * @param b* @param offset*            b的偏移量* @return*/public static long byte2Long(byte[] b, int offset) {return ((((long) b[offset + 0] & 0xff) << 56)| (((long) b[offset + 1] & 0xff) << 48)| (((long) b[offset + 2] & 0xff) << 40)| (((long) b[offset + 3] & 0xff) << 32)| (((long) b[offset + 4] & 0xff) << 24)| (((long) b[offset + 5] & 0xff) << 16)| (((long) b[offset + 6] & 0xff) << 8)| (((long) b[offset + 7] & 0xff) << 0));}/*** byte[8]转long* * @param b* @return*/public static long byte2Long(byte[] b) {return((b[0]&0xff)<<56)|((b[1]&0xff)<<48)|((b[2]&0xff)<<40)|((b[3]&0xff)<<32)|((b[4]&0xff)<<24)|((b[5]&0xff)<<16)|((b[6]&0xff)<<8)|(b[7]&0xff);}/*** long转byte[8]* * @param a* @return*/public static byte[] long2Byte(long a) {byte[] b = new byte[4 * 2];b[0] = (byte) (a >> 56);b[1] = (byte) (a >> 48);b[2] = (byte) (a >> 40);b[3] = (byte) (a >> 32);b[4] = (byte) (a >> 24);b[5] = (byte) (a >> 16);b[6] = (byte) (a >> 8);b[7] = (byte) (a >> 0);return b;}/*** byte数组转int* * @param b* @return*/public static int byte2Int(byte[] b) {return ((b[0] & 0xff) << 24) | ((b[1] & 0xff) << 16)| ((b[2] & 0xff) << 8) | (b[3] & 0xff);}/*** byte数组转int* * @param b* @param offset* @return*/public static int byte2Int(byte[] b, int offset) {return ((b[offset++] & 0xff) << 24) | ((b[offset++] & 0xff) << 16)| ((b[offset++] & 0xff) << 8) | (b[offset++] & 0xff);}/*** int转byte数组* * @param a* @return*/public static byte[] int2Byte(int a) {byte[] b = new byte[4];b[0] = (byte) (a >> 24);b[1] = (byte) (a >> 16);b[2] = (byte) (a >> 8);b[3] = (byte) (a);return b;}/*** int转byte数组* * @param a* @param b* @param offset* @return*/public static void int2Byte(int a, byte[] b, int offset) {		b[offset++] = (byte) (a >> 24);b[offset++] = (byte) (a >> 16);b[offset++] = (byte) (a >> 8);b[offset++] = (byte) (a);}
}


测试代码：

TDSAnalyForSybase sySybase = new TDSAnalyForSybase();
byte[] buff = new byte[1024 * 4];
int ret_read = 0;//....
ret_read = sybaseIn.read(buff);if (sySybase.addPackage(buff, 0, ret_read)) {  //最后一个包System.out.println(sySybase.getSql());
}else{ //非最后一个包，继续读
//...
}
//....



转载于:https://my.oschina.net/tangcoffee/blog/359493

这篇关于Sybase TDS协议分析的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/345229。

相关文章

性能分析之MySQL索引实战案例

性能分析之MySQL索引实战案例

文章目录 一、前言二、准备三、MySQL索引优化四、MySQL 索引知识回顾五、总结 一、前言 在上一讲性能工具之 JProfiler 简单登录案例分析实战中已经发现SQL没有建立索引问题，本文将一起从代码层去分析为什么没有建立索引？ 开源ERP项目地址：https://gitee.com/jishenghua/JSH_ERP 二、准备 打开IDEA找到登录请求资源路径位置
阅读更多...
SWAP作物生长模型安装教程、数据制备、敏感性分析、气候变化影响、R模型敏感性分析与贝叶斯优化、Fortran源代码分析、气候数据降尺度与变化影响分析

SWAP作物生长模型安装教程、数据制备、敏感性分析、气候变化影响、R模型敏感性分析与贝叶斯优化、Fortran源代码分析、气候数据降尺度与变化影响分析

查看原文>>>全流程SWAP农业模型数据制备、敏感性分析及气候变化影响实践技术应用 SWAP模型是由荷兰瓦赫宁根大学开发的先进农作物模型，它综合考虑了土壤-水分-大气以及植被间的相互作用；是一种描述作物生长过程的一种机理性作物生长模型。它不但运用Richard方程，使其能够精确的模拟土壤中水分的运动，而且耦合了WOFOST作物模型使作物的生长描述更为科学。 本文让更多的科研人员和农业工作者
阅读更多...
MOLE 2.5 分析分子通道和孔隙

MOLE 2.5 分析分子通道和孔隙

软件介绍 生物大分子通道和孔隙在生物学中发挥着重要作用，例如在分子识别和酶底物特异性方面。 我们介绍了一种名为 MOLE 2.5 的高级软件工具，该工具旨在分析分子通道和孔隙。 与其他可用软件工具的基准测试表明，MOLE 2.5 相比更快、更强大、功能更丰富。作为一项新功能，MOLE 2.5 可以估算已识别通道的物理化学性质。 软件下载 https://pan.quark.cn/s/57
阅读更多...
衡石分析平台使用手册-单机安装及启动

衡石分析平台使用手册-单机安装及启动

单机安装及启动​ 本文讲述如何在单机环境下进行 HENGSHI SENSE 安装的操作过程。 在安装前请确认网络环境，如果是隔离环境，无法连接互联网时，请先按照 离线环境安装依赖的指导进行依赖包的安装，然后按照本文的指导继续操作。如果网络环境可以连接互联网，请直接按照本文的指导进行安装。 准备工作​ 请参考安装环境文档准备安装环境。 配置用户与安装目录。 在操作前请检查您是否有 sud
阅读更多...
【Linux】应用层http协议

【Linux】应用层http协议

一、HTTP协议 1.1 简要介绍一下HTTP        我们在网络的应用层中可以自己定义协议，但是，已经有大佬定义了一些现成的，非常好用的应用层协议，供我们直接使用，HTTP（超文本传输协议）就是其中之一。        在互联网世界中，HTTP（超文本传输协议）是一个至关重要的协议，他定义了客户端（如浏览器）与服务器之间如何进行通信，以交换或者传输超文本（比如HTML文档）。
阅读更多...
线性因子模型 - 独立分量分析（ICA）篇

线性因子模型 - 独立分量分析（ICA）篇

序言 线性因子模型是数据分析与机器学习中的一类重要模型，它们通过引入潜变量（ latent variables \text{latent variables} latent variables）来更好地表征数据。其中，独立分量分析（ ICA \text{ICA} ICA）作为线性因子模型的一种，以其独特的视角和广泛的应用领域而备受关注。 ICA \text{ICA} ICA旨在将观察到的复杂信号
阅读更多...
【软考】希尔排序算法分析

【软考】希尔排序算法分析

目录 1. c代码2. 运行截图3. 运行解析 1. c代码 #include <stdio.h>#include <stdlib.h> void shellSort(int data[], int n){// 划分的数组，例如8个数则为[4, 2, 1]int *delta;int k;// i控制delta的轮次int i;// 临时变量，换值int temp;in
阅读更多...
三相直流无刷电机(BLDC)控制算法实现：BLDC有感启动算法思路分析

三相直流无刷电机(BLDC)控制算法实现：BLDC有感启动算法思路分析

一枚从事路径规划算法、运动控制算法、BLDC/FOC电机控制算法、工控、物联网工程师，爱吃土豆。如有需要技术交流或者需要方案帮助、需求：以下为联系方式—V 方案1：通过霍尔传感器IO中断触发换相 1.1 整体执行思路 霍尔传感器U、V、W三相通过IO+EXIT中断的方式进行霍尔传感器数据的读取。将IO口配置为上升沿+下降沿中断触发的方式。当霍尔传感器信号发生发生信号的变化就会触发中断在中断
阅读更多...
kubelet组件的启动流程源码分析

kubelet组件的启动流程源码分析

概述 摘要: 本文将总结kubelet的作用以及原理，在有一定基础认识的前提下，通过阅读kubelet源码，对kubelet组件的启动流程进行分析。 正文 kubelet的作用 这里对kubelet的作用做一个简单总结。 节点管理 节点的注册 节点状态更新 容器管理(pod生命周期管理) 监听apiserver的容器事件 容器的创建、删除(CRI) 容器的网络的创建与删除
阅读更多...
PostgreSQL核心功能特性与使用领域及场景分析

PostgreSQL核心功能特性与使用领域及场景分析

PostgreSQL有什么优点？ 开源和免费 PostgreSQL是一个开源的数据库管理系统，可以免费使用和修改。这降低了企业的成本，并为开发者提供了一个活跃的社区和丰富的资源。 高度兼容 PostgreSQL支持多种操作系统（如Linux、Windows、macOS等）和编程语言（如C、C++、Java、Python、Ruby等），并提供了多种接口（如JDBC、ODBC、ADO.NET等
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2