GVKun编程网logo

mssql sql 分页语句（sql的分页）

4

如果您对mssqlsql分页语句感兴趣，那么本文将是一篇不错的选择，我们将为您详在本文中，您将会了解到关于mssqlsql分页语句的详细内容，我们还将为您解答sql的分页的相关问题，并且为您提供关于d

如果您对mssql sql 分页语句感兴趣，那么本文将是一篇不错的选择，我们将为您详在本文中，您将会了解到关于mssql sql 分页语句的详细内容，我们还将为您解答sql的分页的相关问题，并且为您提供关于django 连接 mssql 数据库 (django 1.11.11 sql server 2008 R2)、Java / MSSQL：java.sql.SQLException无效的对象名称“ TableName”、JOOQ 中的 SQL 异常如果 MSSQL 服务器存在、Kafka Connect + JDBC Source 连接器 + JDBC Sink 连接器 + MSSQL SQL Server = IDENTITY_INSERT 问题的有价值信息。

本文目录一览：

mssql sql 分页语句（sql的分页）

mssql sql 分页语句（sql的分页）

mssql sql 语句

sql="select top 1 ddd from id,title,time,sum(id) as vv,a.id,b.id where table1,table2astb2 order by a.title like ''%"&title&"%'' desc" rs.open sql,conn,1,1 if rs.eof then else     ddd = rs("ddd") end if rs.close

 

类型：  查询单条记录  查询多条记录  分页  查询全部记录
 
字段名：   觉得麻烦
 多个字段名用英文逗号隔开
如：id,title,time,sum(id) as 别名,a.id,b.id
 
表名： 
 多个表名用英文逗号隔开
如：table1,table2 as tb2 
条件： 
 支持and，or，注意一下字段的类型，最后的条件字段需要注意
数字型title=''"&title&"'' and id="&id&"
字符型id="&id&" and title=''"&title&"''
多表查询：a.title=''"&title&"''
或者：a.title like ''%"&title&"%'' 
顺序：   降序  升序
 表单中不填，后面的顺序不起作用
多个顺序，用英文逗号隔开，前面的字段请自己加desc或asc，最后一个
不需要加

django 连接 mssql 数据库 (django 1.11.11 sql server 2008 R2)

django 连接 mssql 数据库 (django 1.11.11 sql server 2008 R2)

 

模块使用的是 pcodbc+django-pyodbc-azure

1 pip install django-pyodbc-azure 
2 pip install pyodbc

版本分别为

pyodbc==4.0.26

django-pyodbc-azure==2.1.0.0

创建数据库连接

DATABASES = {
    ''default'': {
        ''ENGINE'': ''sql_server.pyodbc'',
        ''HOST'': ''127.0.0.1'',
        ''PORT'': '''',
        ''NAME'': ''test'',
        ''USER'': ''sa'',
        ''PASSWORD'': ''123'',
        ''OPTIONS'': {
            ''driver'': ''ODBC Driver 13 for SQL Server'',
            ''MARS_Connection'': True,
        }
    }
}

# set this to False if you want to turn off pyodbc''s connection pooling
# 不想用pyodbc连接就把这句加上？
DATABASE_CONNECTION_POOLING = False

在对应的 app/models.py 添加 model 

from django.db import models

# Create your models here.
class userinfo(models.Model):
    #如果没有models.AutoField，默认会创建一个id的自增列
    name = models.CharField(max_length=30)
    email = models.EmailField()
    memo = models.TextField()

项目文件下目录下执行

python manage.py makemigrations
python manage.py migrate

报错

django.db.utils.InterfaceError: (''IM002'', ''[IM002] [Microsoft][ODBC 驱动程序管理器] 未发现数据源名称并且未指定默认驱动程序 (0) (SQLDriverConnect)'')

原因是未安装 ODBC 驱动

前往微软官网下载驱动

https://www.microsoft.com/zh-CN/download/details.aspx?id=53339

Microsoft® ODBC Driver 13.1 for SQL Server

如果下载其他版本 ''driver'': 字段要自行修改 

再次执行

1 python manage.py makemigrations
2 python manage.py migrate

查看数据库

如出现以上表说明连接成功

 

Java / MSSQL：java.sql.SQLException无效的对象名称“ TableName”

Java / MSSQL：java.sql.SQLException无效的对象名称“ TableName”

我正在尝试将Java应用程序从旧服务器移动到新服务器。该应用程序在Tomcat上运行，使用Microsoft SQL
Server作为后端数据库，并使用在数据源（ODBC）中定义的系统DSN来确定连接到的位置。旧服务器使用Windows 2000 / SQL Server
2000，新服务器使用Windows 2003 / SQL Server 2005。

服务器之间的ODBC定义相同，并且定义了要使用的数据库。

在新服务器上，当用户尝试登录时，stdout.log中将显示以下内容：

正在检查用户 错误：java.sql.SQLException：[Microsoft] [ODBC SQL Server驱动程序] [SQL
Server]对象名称’UserTable’无效。

DB中确实存在一个名为 UserTable 的表，但通过管理界面显示为“ dbo.USerTable ”。

我应该调整一下MSSQL中的某个设置，以使其对“ dbo”感到满意。缺少前缀，或者还有其他我想念的东西？

[编辑]使用Windows身份验证，并且作为故障排除步骤，已将公共角色和来宾角色赋予数据库所有权限。

答案1

小编典典

数据库登录是否不同？dbo“前缀”只是对象所定义的架构。因此，如果您的ODBC连接器使用dbo凭据登录，则该对象应位于其默认架构中。

JOOQ 中的 SQL 异常如果 MSSQL 服务器存在

JOOQ 中的 SQL 异常如果 MSSQL 服务器存在

如何解决JOOQ 中的 SQL 异常如果 MSSQL 服务器存在

我正在使用 JOOQ 来动态创建/更改表模式。 我的代码在 postgres 上运行良好，但是当我使用 MSsql Server 时。 我收到了 MS sql 服务器的 sql syntex 异常，但我的代码在 postgres 上运行良好。使用 MS sql 服务器运行代码时，出现以下错误 -

  1. 2021-05-31 16:02:23.442 ERROR 26552 --- [nio-8080-exec-1] o.a.c.c.C.[.[.[.[dispatcherServlet]      : Servlet.service() for servlet [dispatcherServlet] in context with path [/multi] threw exception [Request processing Failed; nested exception is org.springframework.jdbc.UncategorizedsqlException: jOOQ; uncategorized sqlException for sql [create schema if not exists "test11"]; sql state [S0001]; error code [156]; Incorrect Syntax near the keyword ''if''.; nested exception is com.microsoft.sqlserver.jdbc.sqlServerException: Incorrect Syntax near the keyword ''if''.] with root cause
  3. com.microsoft.sqlserver.jdbc.sqlServerException: Incorrect Syntax near the keyword ''if''.
  4.     at com.microsoft.sqlserver.jdbc.sqlServerException.makeFromDatabaseError(sqlServerException.java:262) ~[mssql-jdbc-7.4.1.jre8.jar:na]
  5.     at com.microsoft.sqlserver.jdbc.sqlServerStatement.getNextResult(sqlServerStatement.java:1624) ~[mssql-jdbc-7.4.1.jre8.jar:na]
  6.     at com.microsoft.sqlserver.jdbc.sqlServerPreparedStatement.doExecutePreparedStatement(sqlServerPreparedStatement.java:594) ~[mssql-jdbc-7.4.1.jre8.jar:na]
  7.     at com.microsoft.sqlserver.jdbc.sqlServerPreparedStatement$PrepStmtExecCmd.doExecute(sqlServerPreparedStatement.java:524) ~[mssql-jdbc-7.4.1.jre8.jar:na]
  8.     at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194) ~[mssql-jdbc-7.4.1.jre8.jar:na]
  9.     at com.microsoft.sqlserver.jdbc.sqlServerConnection.executeCommand(sqlServerConnection.java:2979) ~[mssql-jdbc-7.4.1.jre8.jar:na]
  10.     at com.microsoft.sqlserver.jdbc.sqlServerStatement.executeCommand(sqlServerStatement.java:248) ~[mssql-jdbc-7.4.1.jre8.jar:na]
  11.     at com.microsoft.sqlserver.jdbc.sqlServerStatement.executeStatement(sqlServerStatement.java:223) ~[mssql-jdbc-7.4.1.jre8.jar:na]
  12.     at com.microsoft.sqlserver.jdbc.sqlServerPreparedStatement.execute(sqlServerPreparedStatement.java:505) ~[mssql-jdbc-7.4.1.jre8.jar:na]
  13.     at com.zaxxer.hikari.pool.ProxyPreparedStatement.execute(ProxyPreparedStatement.java:44) ~[HikariCP-3.4.5.jar:na]
  14.     at com.zaxxer.hikari.pool.HikariProxyPreparedStatement.execute(HikariProxyPreparedStatement.java) ~[HikariCP-3.4.5.jar:na]
  15.     at org.jooq.tools.jdbc.DefaultPreparedStatement.execute(DefaultPreparedStatement.java:209) ~[jooq-3.13.5.jar:na]
  16.     at org.jooq.impl.AbstractQuery.execute(AbstractQuery.java:453) ~[jooq-3.13.5.jar:na]
  17.     at org.jooq.impl.AbstractQuery.execute(AbstractQuery.java:371) ~[jooq-3.13.5.jar:na]
  18.     at com.amitr.demomultitenant.ContaxtResolver.setTenantSchemaInDSLContext(ContaxtResolver.java:15) ~[classes/:na]
  19.     at com.amitr.interceptor.RequestInterceptor.preHandle(RequestInterceptor.java:34) ~[classes/:na]
  20.     at org.springframework.web.servlet.HandlerExecutionChain.applyPreHandle(HandlerExecutionChain.java:151) ~[spring-webmvc-5.2.10.RELEASE.jar:5.2.10.RELEASE]
  21.     at org.springframework.web.servlet.dispatcherServlet.dodispatch(dispatcherServlet.java:1035) ~[spring-webmvc-5.2.10.RELEASE.jar:5.2.10.RELEASE]
  22.     at org.springframework.web.servlet.dispatcherServlet.doService(dispatcherServlet.java:943) ~[spring-webmvc-5.2.10.RELEASE.jar:5.2.10.RELEASE]
  23.     at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006) ~[spring-webmvc-5.2.10.RELEASE.jar:5.2.10.RELEASE]
  24.     at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:909) ~[spring-webmvc-5.2.10.RELEASE.jar:5.2.10.RELEASE]
  25.     at javax.servlet.http.HttpServlet.service(HttpServlet.java:652) ~[tomcat-embed-core-9.0.39.jar:4.0.FR]
  26.     at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883) ~[spring-webmvc-5.2.10.RELEASE.jar:5.2.10.RELEASE]
  27.     at javax.servlet.http.HttpServlet.service(HttpServlet.java:733) ~[tomcat-embed-core-9.0.39.jar:4.0.FR]
  28.     at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  29.     at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  30.     at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53) ~[tomcat-embed-websocket-9.0.39.jar:9.0.39]
  31.     at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  32.     at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  33.     at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100) ~[spring-web-5.2.10.RELEASE.jar:5.2.10.RELEASE]
  34.     at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) ~[spring-web-5.2.10.RELEASE.jar:5.2.10.RELEASE]
  35.     at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  36.     at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  37.     at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93) ~[spring-web-5.2.10.RELEASE.jar:5.2.10.RELEASE]
  38.     at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) ~[spring-web-5.2.10.RELEASE.jar:5.2.10.RELEASE]
  39.     at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  40.     at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  41.     at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201) ~[spring-web-5.2.10.RELEASE.jar:5.2.10.RELEASE]
  42.     at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) ~[spring-web-5.2.10.RELEASE.jar:5.2.10.RELEASE]
  43.     at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  44.     at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  45.     at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:202) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  46.     at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:97) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  47.     at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:542) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  48.     at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:143) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  49.     at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  50.     at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:78) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  51.     at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  52.     at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:374) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  53.     at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:65) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  54.     at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:868) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  55.     at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1590) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  56.     at org.apache.tomcat.util.net.socketProcessorBase.run(SocketProcessorBase.java:49) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  57.     at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[na:na]
  58.     at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[na:na]
  59.     at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) ~[tomcat-embed-core-9.0.39.jar:9.0.39]
  60.     at java.base/java.lang.Thread.run(Thread.java:834) ~[na:na]

下面是我遇到错误的代码 -

  1. context.createSchemaifNotExists(schemaName).execute();

有人可以帮我吗？

Kafka Connect + JDBC Source 连接器 + JDBC Sink 连接器 + MSSQL SQL Server = IDENTITY_INSERT 问题

Kafka Connect + JDBC Source 连接器 + JDBC Sink 连接器 + MSSQL SQL Server = IDENTITY_INSERT 问题

如何解决Kafka Connect + JDBC Source 连接器 + JDBC Sink 连接器 + MSSQL SQL Server = IDENTITY_INSERT 问题

我试图弄清楚为什么我在尝试使用 JDBC 接收器连接器将数据从主题接收到 sql Server 数据库时收到“IDENTITY_INSERT”错误，该主题也由连接到的 JDBC 源连接器写入相同的 sql Server 数据库。

总体目标：

目前有一个 sql Server 数据库被后端用于传统意义上的存储，我们正在尝试过渡到使用 Kafka 来实现所有相同的目的，但是 sql Server 数据库暂时必须保留为有些服务仍然依赖它，我们要求将 Kafka 上的所有数据镜像到 sql Server 数据库中。

我正在努力实现的目标：

我正在尝试创建一个设置，其中包含以下内容：

  • 一个 sql Server 数据库（所有具有相同主键“id”的表，该主键自动递增并由 sql Server 设置）
  • Kafka 集群，包括 Kafka 连接：
    • 用于将 sql Server 表中的内容同步到 kafka 主题的 JDBC 源连接器，对于主题和表，我们将其称为 AccountType
    • 订阅相同主题的 JD Sink 连接器 AccountType 并将数据接收到 sql Server 数据库中相同的 AccountType 表

预期行为是：

  • 如果旧服务在 sql Server 中写入/更新记录
    • 源连接器将获取更改并将其写入相应的 Kafka 主题
    • 接收器连接器将收到关于同一主题的消息，但是，由于更改源自 sql Server，因此已经从接收器连接器的角度进行了更改，接收器连接器将在主键上找到匹配项，请参阅没有改变，继续前进
  • 如果设计用于与 Kafka 一起使用的新服务更新记录并将其写入正确的主题：
    • JDBC sink 连接器将接收关于主题的消息作为偏移量
    • 由于 sink 连接器配置了 upsert 模式，它会在目标数据库中找到主键的匹配项并更新目标数据库中的相应记录
    • 然后源连接器将检测到更改，触发其将更改写入相应的主题
    • 此时我的假设是以下两种情况之一会发生：
      • 源连接器不会写入主题，因为它只会复制最后一条消息或
      • 源连接器会将重复的消息写入主题，但是它会被接收器忽略，因为不会导致数据库记录更改

这种预期行为与我在文档中找到的所有内容一致，并且尽我所能，根据此处找到的 JDBC sink 深度潜水指南：https://rmoff.net/2021/03/12/kafka-connect-jdbc-sink-deep-dive-working-with-primary-keys/[kafka-connect-jdbc-sink-deep-dive-working-with-primary-keys][1]

正在发生的事情：

  • Kafka 集群全部启动，数据库为空，两个连接器都创建成功
  • 使用外部服务将一行插入到数据库的表中
  • 源连接器成功获取更改并将记录写入 Kafka 上的主题（该主题已被转换拆分，因此表示 sql Server 表 PK 的字段已被提取并设置为消息键，并删除从值）
  • （问题）接收器连接器然后收到有关该主题的消息，然后...

...这是问题，根据我能找到的几个视频和示例，应该不会发生任何事情，因为该记录在数据库中已经是最新的，但是，它会立即尝试按原样编写整个消息,到目标表，结果如下：

java.sql.BatchUpdateException：当 IDENTITY_INSERT 设置为 OFF 时，无法为表“AccountType”中的标识列插入显式值。

这是有道理的，因为来自主题的消息中有一个主键字段，如果它没有在表中启用，那么它就不应该被允许。只是为了好玩，我尝试在尝试写入之前进行额外的转换以删除 id 字段，而是使用表中的另一个字段，该字段在配置中具有“唯一”约束。当我这次重复这些步骤时，它没有抱怨写入主键，但它仍然立即尝试插入导致另一个错误的记录，因为它会违反唯一约束，这又是完全合理的。

我被困的地方：

如果以上所有内容都有意义，谁能告诉我为什么尽管设置为 upsert，它仍会自动尝试插入？

注意事项：

  • 所有这些都是使用 confluent 为 confluent 平台版本 6.2.0 提供的 docker 容器设置的

源连接器配置：

  1. {
  2.   "connection.url": "jdbc:sqlserver://mssql:1433;databaseName=REDACTED","connection.user":"REDACTED","connection.password":"REDACTED","connection.attempts": "3","connection.backoff.ms": "5000","table.whitelist": "AccountType","db.timezone": "UTC","name": "sql-server-source","connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector","dialect.name": "sqlServerDatabaseDialect","config.action.reload": "restart","topic.creation.enable": "false","tasks.max": "1","mode": "timestamp+incrementing","incrementing.column.name": "id","timestamp.column.name": "created,updated","validate.non.null": true,"key.converter": "org.apache.kafka.connect.converters.LongConverter","value.converter": "io.confluent.connect.json.JsonSchemaConverter","value.converter.schema.registry.url": "http://schema-registry:8081","auto.register.schemas": "true","schema.registry.url": "http://schema-registry:8081","errors.log.include.messages": "true","transforms": "copyFieldToKey,extractKeyFromStruct,removeKeyFromValue","transforms.copyFieldToKey.type": "org.apache.kafka.connect.transforms.ValuetoKey","transforms.copyFieldToKey.fields": "id","transforms.extractKeyFromStruct.type":                         
  3.   "org.apache.kafka.connect.transforms.ExtractField$Key","transforms.extractKeyFromStruct.field": "id","transforms.removeKeyFromValue.type": 
  4.   "org.apache.kafka.connect.transforms.ReplaceField$Value","transforms.removeKeyFromValue.blacklist": "id","transforms.extractKeyFromStruct.type": 
  5.   "org.apache.kafka.connect.transforms.ExtractField$Key",}

接收器连接器配置：

  1. {
  2.   "connection.url": "jdbc:sqlserver://mssql:1433;databaseName=REDACTED","table.name.format": "${topic}","name": "sql-server-sink","connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector","auto.create": "false","auto.evolve": "false","batch.size": "1000","topics": "AccountType","insert.mode": "UPSERT","pk.mode": "record_key","pk.fields": "id",}

关于mssql sql 分页语句和sql的分页的介绍已经告一段落，感谢您的耐心阅读，如果想了解更多关于django 连接 mssql 数据库 (django 1.11.11 sql server 2008 R2)、Java / MSSQL：java.sql.SQLException无效的对象名称“ TableName”、JOOQ 中的 SQL 异常如果 MSSQL 服务器存在、Kafka Connect + JDBC Source 连接器 + JDBC Sink 连接器 + MSSQL SQL Server = IDENTITY_INSERT 问题的相关信息，请在本站寻找。

本文标签：

上一篇mssql 收缩数据库与收缩数据和日志 sql语句（sql收缩数据库日志的几种办法）

下一篇mssql 压缩数据库 检查备份集 修复数据库 sql语句（sqlserver压缩备份数据库）

相关文章