前端技术
HTML
CSS
Javascript
前端框架和UI库
VUE
ReactJS
AngularJS
JQuery
NodeJS
JSON
Element-UI
Bootstrap
Material UI
服务端和客户端
Java
Python
PHP
Golang
Scala
Kotlin
Groovy
Ruby
Lua
.net
c#
c++
后端WEB和工程框架
SpringBoot
SpringCloud
Struts2
MyBatis
Hibernate
Tornado
Beego
Go-Spring
Go Gin
Go Iris
Dubbo
HessianRPC
Maven
Gradle
数据库
MySQL
Oracle
Mongo
中间件与web容器
Redis
MemCache
Etcd
Cassandra
Kafka
RabbitMQ
RocketMQ
ActiveMQ
Nacos
Consul
Tomcat
Nginx
Netty
大数据技术
Hive
Impala
ClickHouse
DorisDB
Greenplum
PostgreSQL
HBase
Kylin
Hadoop
Apache Pig
ZooKeeper
SeaTunnel
Sqoop
Datax
Flink
Spark
Mahout
数据搜索与日志
ElasticSearch
Apache Lucene
Apache Solr
Kibana
Logstash
数据可视化与OLAP
Apache Atlas
Superset
Saiku
Tesseract
系统与容器
Linux
Shell
Docker
Kubernetes
[PreparedStatement 执行...]的搜索结果
这里是文章列表。热门标签的颜色随机变换,标签颜色没有特殊含义。
点击某个标签可搜索标签相关的文章。
点击某个标签可搜索标签相关的文章。
.net
...如匿名方法、LINQ查询等。你知道吗?C这门编程语言有个大大的优点,那就是性能杠杠的!特别是在Windows系统上,用C编译出的代码那跑起来简直是飞一般的感觉,速度快到没朋友!另外,C还自带了一大堆超实用的类库和API工具箱,这让开发者们能轻轻松松地写出高效能的应用程序,就像在厨房里有了一整套齐全的厨具,做起菜来更加得心应手。 下面是一个简单的C程序示例: csharp using System; namespace HelloWorld { class Program { static void Main(string[] args) { Console.WriteLine("Hello, World!"); } } } 在这个程序中,我们定义了一个名为HelloWorld的程序集,并在其中定义了一个名为Program的类。然后,在我们的程序中心点——Main方法里头,我们让计算机蹦出了“Hello, World!”这句话。这就是咱们这个小程序最核心、最精髓的部分啦! 3. Visual Basic Visual Basic是一种可视化编程语言,它的语法比较简单,易于学习和使用,非常适合初学者入门。你知道吗,Visual Basic有个超赞的优点——它自带了一大堆可视化的小玩意儿和控件,这就像是给开发者准备了一整套积木。用这些积木,开发者可以像搭房子一样轻松快速地搭建出既好看又实用的应用界面,省时又省力,可酷了!此外,Visual Basic还支持许多高级特性,如事件驱动编程、多线程编程等。 下面是一个简单的Visual Basic程序示例: vbnet Module Module1 Sub Main() Console.WriteLine("Hello, World!") End Sub End Module 在这个程序中,我们定义了一个名为Module1的模块,并在其中定义了一个名为Main的方法。然后,我们在Main方法中打印出了字符串"Hello, World!",这也是我们的程序的核心逻辑。 4. C和Visual Basic的区别 虽然C和Visual Basic都是.NET的一部分,但是它们之间还是存在很多差异的。首先,咱从语言这一块儿来说,C这门语言的语法确实有点儿绕,不过人家可是藏着更多的功能和特性呢,就像是个大宝箱。而Visual Basic呢,就更像是一本初级读物,学起来轻松简单,特别适合刚入门的小白朋友来上手。其次,从性能角度来看,C编译出来的代码运行速度更快,而Visual Basic则相对较慢。最后,从实际应用场景来瞅瞅,C这门语言就像是为开发大型企业级应用而量身定制的,特别对路。相比之下,Visual Basic更适合捣鼓些小型桌面应用或者小游戏啥的,更加接地气儿。 5. 总结 总的来说,C和Visual Basic都是.NET的重要组成部分,各自有着自己的优势和适用场景。选择哪一种语言,应该根据实际的需求和情况来决定。不论你挑了哪种语言,只要你摸透了它的基本脾性和使用窍门,就绝对能捣鼓出顶尖水准的应用程序来。 感谢您阅读这篇文章,希望我的回答能够帮助到您!如果您有任何其他问题,欢迎随时联系我,我会尽全力为您解答。
2023-07-31 15:48:21
567
幽谷听泉-t
RabbitMQ
...列数据,并提供灵活的查询语句和可视化展示功能。在本文的上下文中,Prometheus被用来实时抓取并分析RabbitMQ的各项性能指标,如消息收发速率、消息丢失率等,以便运维人员能够及时发现和解决问题,保障RabbitMQ服务的稳定运行。 Docker , Docker是一款容器化平台技术,它允许开发者打包应用及其依赖项到一个可移植的容器中,从而实现应用程序的一致性部署和运行。在调试网络波动对RabbitMQ性能的影响时,文章建议使用Docker搭建模拟网络波动的测试环境。通过创建包含网络波动模拟器的Docker镜像,用户可以在受控环境中重现网络问题,进而对RabbitMQ的性能表现进行深入的诊断和优化。
2023-10-10 09:49:37
99
青春印记-t
ClickHouse
...件系统的外部表,但在查询时收到错误提示:“Access to file denied”,这通常意味着ClickHouse服务账户没有足够的权限访问该文件。 sql CREATE TABLE external_table (event Date, id Int64) ENGINE = File(Parquet, '/path/to/your/file.parquet'); SELECT FROM external_table; -- Access to file denied 3.2 解决方案 首先,我们需要确认ClickHouse服务运行账户对目标文件或目录拥有读取权限。可以通过更改文件或目录的所有权或修改访问权限来实现: bash sudo chown -R clickhouse:clickhouse /path/to/your/file.parquet sudo chmod -R 750 /path/to/your/file.parquet 这里,“clickhouse”是ClickHouse服务默认使用的系统账户名,您需要将其替换为您的实际环境下的账户名。对了,你知道吗?这个“750”啊,就像是个门锁密码一样,代表着一种常见的权限分配方式。具体来说呢,就是文件的所有者,相当于家的主人,拥有全部权限——想读就读,想写就写,还能执行操作;同组的其他用户呢,就好比是家人或者室友,他们能读取文件内容,也能执行相关的操作,但就不能随意修改了;而那些不属于这个组的其他用户呢,就像是门外的访客,对于这个文件来说,那可是一点权限都没有,完全进不去。 4. 文件不存在的问题及其解决策略 4.1 问题描述 当我们在创建外部表时指定的文件路径无效或者文件已被删除时,尝试从该表查询数据会返回“File not found”的错误。 sql CREATE TABLE missing_file_table (data String) ENGINE = File(TSV, '/nonexistent/path/file.tsv'); SELECT FROM missing_file_table; -- File not found 4.2 解决方案 针对此类问题,我们的首要任务是确保指定的文件路径是存在的并且文件内容有效。若文件确实已被移除,那么重新生成或恢复文件是最直接的解决办法。另外,你还可以琢磨一下在ClickHouse的配置里头开启自动监控和重试功能,这样一来,万一碰到文件临时抽风、没法用的情况,它就能自己动手解决问题了。 另外,对于周期性更新的外部数据源,推荐结合ALTER TABLE ... UPDATE语句或MaterializeMySQL等引擎动态更新外部表的数据源路径。 sql -- 假设新文件已经生成,只需更新表结构即可 ALTER TABLE missing_file_table MODIFY SETTING path = '/new/existing/path/file.tsv'; 5. 结论与思考 在使用ClickHouse外部表的过程中,理解并妥善处理文件系统权限和文件状态问题是至关重要的。只有当数据能够被安全、稳定地访问,才能充分发挥ClickHouse在大数据分析领域的强大效能。这也正好敲响我们的小闹钟,在我们捣鼓数据架构和运维流程的设计时,千万不能忘了把权限控制和数据完整性这两块大骨头放进思考篮子里。这样一来,咱们才能稳稳当当地保障整个数据链路健健康康地运转起来。
2023-09-29 09:56:06
467
落叶归根
DorisDB
...了在DorisDB中执行一条简单的插入语句,尽管实际过程涉及到了复杂的分布式事务处理逻辑,但用户无需关心这些细节,DorisDB会自动保障数据的一致性。 3. 多版本并发控制(MVCC)实现无锁并发写入 DorisDB引入了多版本并发控制(MVCC)机制,进一步提升了并发写入的性能和数据一致性。在MVCC这个机制里头,每当有写操作的时候,它不会直接去碰原有的数据,而是巧妙地创建一个新的数据版本来进行更新。这样一来,读和写的操作就能同时开足马力进行了,完全不用担心像传统锁那样,一个操作卡住,其他的操作就得干等着的情况发生。 sql -- 在DorisDB中,即使有多个并发写入请求,也能保证数据一致性 BEGIN TRANSACTION; UPDATE my_table SET column1='new_value1' WHERE key=1; COMMIT; -- 同时发生的另一个写入操作 BEGIN TRANSACTION; UPDATE my_table SET column2='new_value2' WHERE key=1; COMMIT; 上述两个并发更新操作,即便针对的是同一行数据,DorisDB也能借助MVCC机制在保证数据一致性的前提下顺利完成,且不会产生数据冲突。 4. 高效的错误恢复与重试机制 对于可能出现的数据写入失败情况,DorisDB具备高效的错误恢复与重试机制。如果你在写东西时,突然网络抽风或者节点罢工导致没写成功,别担心,系统可机灵着呢,它能自动察觉到这个小插曲。然后,它会不厌其烦地尝试再次写入,直到你的数据稳稳当当地落到所有备份里头,确保最后数据的完整性是一致滴。 5. 总结与展望 面对数据一致性这一棘手难题,DorisDB凭借其独特的强一致性模型、多版本并发控制以及高效错误恢复机制,为企业提供了可靠的数据存储解决方案。甭管是那种超大型的实时数据分析活儿,还是对数据准确性要求严苛到极致的关键业务场景,DorisDB都能稳稳接住挑战,确保数据的价值被淋漓尽致地挖掘出来,发挥到最大效能。随着技术的不断进步和升级,我们对DorisDB寄予厚望,期待它在未来能够更加给力,提供更牛的数据一致性保障,帮助更多的企业轻松搭上数字化转型这趟高速列车,跑得更快更稳。
2023-07-01 11:32:13
485
飞鸟与鱼
ElasticSearch
...sticsearch查询和分析这些数据。好了,假设你已经把日志数据成功导入到了Elasticsearch里,现在你想看看最近一天内哪些网址被访问得最多。 bash GET /nginx-access-/_search { "size": 0, "aggs": { "top_pages": { "terms": { "field": "request", "size": 10 } } } } 这段查询语句会返回过去一天内访问量最高的10个URL。通过这种方式,你可以快速获取关键信息,从而做出相应的决策。 6. 总结与展望 通过这篇文章,我们学习了如何使用Elasticsearch异步采集非业务数据,并进行了简单的分析。这个过程让我们更懂用户的套路,还挖出了不少宝贝,帮我们更好地升级产品和服务。 当然,实际操作中可能会遇到各种问题和挑战,但只要保持耐心,不断实践和探索,相信你一定能够掌握这项技能。希望这篇教程能对你有所帮助,如果你有任何疑问或者建议,欢迎随时留言交流! --- 好了,朋友们,今天的分享就到这里。希望你能从中获得灵感,开始你的Elasticsearch之旅。记住,技术的力量在于应用,让我们一起用它来创造更美好的世界吧!
2024-12-29 16:00:49
75
飞鸟与鱼_
PostgreSQL
...,但强烈建议你总是为查询加上一个排序条件,因为没有明确的排序规则时,返回的数据可能会出现不一致的情况。 2.2 实战演练:分页查询实例 假设你有一个名为products的表,里面存储了各种产品的信息,你想实现一个分页功能来展示这些产品。首先,你得搞清楚用户现在要看的是哪一页(就是每页显示多少条记录),然后用这个信息算出正确的OFFSET值。这样子才能让用户的请求对上数据库里的数据。 sql -- 假设每页显示10条记录 WITH page AS ( SELECT product_id, name, price, ROW_NUMBER() OVER (ORDER BY product_id) AS row_number FROM products ) SELECT FROM page WHERE row_number BETWEEN (page_number - 1) items_per_page + 1 AND page_number items_per_page; 这里的page_number和items_per_page是根据前端传入的参数动态计算出来的。这样,无论用户请求的是第几页,你都可以正确地返回对应的数据。 2.3 排序的魅力 排序同样重要。通过在查询中添加ORDER BY子句,我们可以控制数据的输出顺序。比如,如果你想按价格降序排列产品列表,可以这样写: sql SELECT FROM products ORDER BY price DESC; 或者,如果你想让用户能够自由选择排序方式,可以在应用层接收用户的输入,并相应地调整SQL语句中的排序条件。 3. 结合分页与排序 实战案例 接下来,让我们将分页和排序结合起来,看看实际效果。咱们有个卖东西的网站,得弄个页面能让大伙儿按不同的标准(比如说价格高低、卖得快不快这些)来排产品。这样大家找东西就方便多了。 sql WITH sorted_products AS ( SELECT FROM products ORDER BY CASE WHEN :sort_by = 'price' THEN price END ASC, CASE WHEN :sort_by = 'sales' THEN sales END DESC ) SELECT FROM sorted_products LIMIT :items_per_page OFFSET (:page_number - 1) :items_per_page; 在这个例子中,:sort_by、:items_per_page和:page_number都是从用户输入或配置文件中获取的变量。这种方式使得我们的查询更加灵活,能够适应不同的业务场景。 4. 总结与反思 通过这篇文章,我们探索了如何在PostgreSQL中有效地实现数据的分页和排序功能。别看这些技术好像挺简单,其实它们对提升用户体验和让系统跑得更顺畅可重要着呢!当然啦,随着项目的不断推进,你可能会碰到更多棘手的问题,比如说要应对大量的同时访问,还得绞尽脑汁优化查询速度啥的。不过别担心,掌握了基础之后,一切都会变得容易起来。 希望这篇技术分享对你有所帮助,也欢迎你在评论区分享你的想法和经验。让我们一起进步,共同成长! --- 这就是我关于“如何在数据库中实现数据的分页和排序功能?”的全部内容啦!如果你对PostgreSQL或者其他数据库技术有任何疑问或见解,记得留言哦。编程路上,我们一起加油!
2024-10-17 16:29:27
54
晚秋落叶
Hive
...种SQL-like的查询语言(HiveQL),使得用户能够更方便地在大规模分布式存储系统中进行数据查询和分析。通过将复杂的MapReduce编程工作转化为简单的SQL语句,大大降低了大数据处理的门槛。 Hadoop , Hadoop是一个开源的大数据处理框架,由Apache软件基金会开发并维护。其核心组件包括Hadoop Distributed File System (HDFS) 和 Yet Another Resource Negotiator (YARN),以及用于数据处理的MapReduce编程模型。Hadoop设计目标是支持跨集群的海量数据分布式存储和计算,实现高效、可靠、可扩展的数据处理能力。 Hive SQL , Hive SQL是一种针对Apache Hive定制的类SQL查询语言,也称为HiveQL。尽管与传统的SQL相似,但Hive SQL在功能上有所简化和调整,旨在适应大规模数据集的查询和分析需求。通过Hive SQL,用户可以使用熟悉的SQL语法操作存储在Hadoop中的数据,同时支持对数据进行ETL(抽取、转换、加载)等操作,并能执行聚合、过滤等多种复杂查询。 数据分区 , 在Hive中,数据分区是一种物理数据组织策略,类似于数据库中的表分区。通过指定一个或多个列作为分区键,Hive可以将大表的数据按照分区键的值划分成多个子目录,每个子目录包含符合特定分区键值的数据文件。这样不仅可以优化查询性能,只扫描需要的分区,还能更好地管理数据,提高查询效率。 LLAP(Live Long and Process) , LLAP是Apache Hive项目的一个重要特性,全称为Low Latency Analytical Processing。它引入了内存计算和并发处理机制,为Hive提供了交互式查询服务。在LLAP模式下,查询任务的一部分会在内存中持久运行,从而极大地减少了查询响应时间,提高了Hive在处理大量实时或近实时查询时的表现。
2023-06-17 13:08:12
589
山涧溪流-t
转载文章
...列均逆序排序的方式,查询出前5条,将SQL语句与执行结果截图粘贴至对应报告中; spark.sql("select nationkey,regexp_replace(nationname,'\'','') as nationname,regionkey,regexp_replace(regionname,'\'','') as regionname,sum(totalnum) as totalorder,sum(totalprice) as totalconsumption,year,month from nationeverymonth group by nationkey,regionkey,month,nationname,year,regionname;") 我为了方便查询和之后的操作,将上面的查询结果导入到新表nationeverymonths 查表 接下来将hive中的数据导入mysql中 package com.atguigu.spark.sqlimport org.apache.spark.SparkConfimport org.apache.spark.sql.SparkSessionimport java.util.Propertiesobject DataHiveToMySQL {def main(args: Array[String]): Unit = {val sparkConf = new SparkConf().setMaster("local[]").setAppName("sparkSQL")val spark = SparkSession.builder().enableHiveSupport().config(sparkConf).getOrCreate()val result=spark.sql("select from ods.nationeverymonths")val props=new Properties()props.setProperty("user","root")props.setProperty("password","123456")props.setProperty("driver","com.mysql.jdbc.Driver")result.write.mode("overwrite").jdbc("jdbc:mysql://192.168.230.132:3306/user?serverTimezone=UTC&characterEncoding=UTF-8&useSSL=false", "nationeverymonth", props)println("导入成功")spark.stop()} } 运行可见导入成功 进入MySQL中查看结果 可见数据成功导入 接下来按照要求查询: 2.请根据dwd层表计算出某年每个国家的平均消费额和所有国家平均消费额相比较结果(“高/低/相同”),存入MySQL数据库shtd_store的nationavgcmp表(表结构如下)中,然后在Linux的MySQL命令行中根据订单总数、消费总额、国家表主键三列均逆序排序的方式,查询出前5条,将SQL语句与执行结果截图粘贴至对应报告中; 在解这道题的时候遇见一个问题,在求所有国家平均消费额的时候一直报错,由于没有数据这道题的题意还是有点没看明白,于是我就用了最简单的办法先新增一列,再单独将所有国家平均消费额求出来然后再插入,如果各位大佬有解决这个问题的办法希望能指导一下 先将每个国家的平均消费额求出来 spark.sql("select nationkey,nationname,avg(totalconsumption) as nationavgconsumption from nationeverymonths group by nationkey,nationname") 再新增一列所有国家平均消费额 spark.sql("alter table nationeverymonths add columns(avg_allstring)") 再将查询到的所有国家平均消费额导入进去 spark.sql("insert overwrite table nationeverymonths1 select nationkey,nationname,avg_totalconsumpt,1500 from nationeverymonths1") 再次查表 按照题意添加比较结果字段 spark.sql("select ,case when avg_totalconsumpt>avg_all then '高' when avg_totalconsumpt<avg_all then '低' when avg_totalconsumpt=avg_all then '相同' else 'null' end as comparison from nationeverymonths1").show 最后的排序语句和题一一样 本篇文章为转载内容。原文链接:https://blog.csdn.net/guo_0423/article/details/126352162。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-09-01 10:55:33
319
转载
MySQL
...S这家伙可不懂SQL查询这门子事儿,所以啊,如果我们想对数据进行更深度的分析和复杂的查询操作,就得先把数据从HDFS里导出来,然后存到像是MySQL这样的SQL数据库中才行。 步骤一:设置环境 首先,我们需要确保已经安装了所有必要的工具和软件。以下是您可能需要的一些组件: - Apache Sqoop:这是一个用于在Hadoop和关系型数据库之间进行数据迁移的工具。 - MySQL:这是一个流行的开源关系型数据库管理系统。 - Java Development Kit (JDK):这是开发Java应用程序所必需的一组工具。 在Windows上,你可以在这里找到Java JDK的下载链接:https://www.oracle.com/java/technologies/javase-downloads.html 。在MacOS上,你可以在这里找到Java JDK的下载链接:https://jdk.java.net/15/ 步骤二:配置Hadoop和MySQL 在开始之前,请确保您的Hadoop和MySQL已经正确配置并运行。 对于Hadoop,您可以查看以下教程:https://hadoop.apache.org/docs/r2.7.3/hadoop-project-dist/hadoop-common/SingleCluster.html 对于MySQL,您可以参考官方文档:https://dev.mysql.com/doc/refman/8.0/en/installing-binary-packages.html 步骤三:创建MySQL表 在开始导出数据之前,我们需要在MySQL中创建一个表来存储数据。以下是一个简单的例子: CREATE TABLE students ( id int(11) NOT NULL AUTO_INCREMENT, name varchar(45) DEFAULT NULL, age int(11) DEFAULT NULL, PRIMARY KEY (id) ) ENGINE=InnoDB DEFAULT CHARSET=utf8; 这个表将包含学生的ID、姓名和年龄字段。 步骤四:编写Sqoop脚本 现在我们可以使用Sqoop将HDFS中的数据导入到MySQL表中。以下是一个基本的Sqoop脚本示例: bash -sqoop --connect jdbc:mysql://localhost:3306/test \ -m 1 \ --num-mappers 1 \ --target-dir /user/hadoop/students \ --delete-target-dir \ --split-by id \ --as-textfile \ --fields-terminated-by '|' \ --null-string 'NULL' \ --null-non-string '\\N' \ --check-column id \ --check-nulls \ --query "SELECT id, name, age FROM students WHERE age > 18" 这个脚本做了以下几件事: - 使用--connect选项连接到MySQL服务器和测试数据库。 - 使用-m和--num-mappers选项设置映射器的数量。在这个例子中,我们只有一个映射器。 - 使用--target-dir选项指定输出目录。在这个例子中,我们将数据导出到/user/hadoop/students目录下。 - 使用--delete-target-dir选项删除目标目录中的所有内容,以防数据冲突。 - 使用--split-by选项指定根据哪个字段进行拆分。在这个例子中,我们将数据按学生ID进行拆分。 - 使用--as-textfile选项指定数据格式为文本文件。 - 使用--fields-terminated-by选项指定字段分隔符。在这个例子中,我们将字段分隔符设置为竖线(|)。 - 使用--null-string和--null-non-string选项指定空值的表示方式。在这个例子中,我们将NULL字符串设置为空格,将非字符串空值设置为\\N。 - 使用--check-column和--check-nulls选项指定检查哪个字段和是否有空值。在这个例子中,我们将检查学生ID是否为空,并且如果有,将记录为NULL。 - 使用--query选项指定要从中读取数据的SQL查询语句。在这个例子中,我们只选择年龄大于18的学生。 请注意,这只是一个基本的示例。实际的脚本可能会有所不同,具体取决于您的数据和需求。 步骤五:运行Sqoop脚本 最后,我们可以使用以下命令运行Sqoop脚本: bash -sqoop \ -Dmapreduce.job.user.classpath.first=true \ --libjars $SQOOP_HOME/lib/mysql-connector-java-8.0.24.jar \ --connect jdbc:mysql://localhost:3306/test \ -m 1 \ --num-mappers 1 \ --target-dir /user/hadoop/students \ --delete-target-dir \ --split-by id \ --as-textfile \ --fields-terminated-by '|' \ --null-string 'NULL' \ --null-non-string '\\N' \ --check-column id \ --check-nulls \ --query "SELECT id, name, age FROM students WHERE age > 18" 注意,我们添加了一个-Dmapreduce.job.user.classpath.first=true参数,这样就可以保证我们的自定义JAR包在任务的classpath列表中处于最前面的位置。 如果一切正常,我们应该可以看到一条成功的消息,并且可以在MySQL中看到导出的数据。 总结 本文介绍了如何使用Apache Sqoop将HDFS中的数据导出到MySQL数据库。咱们先给环境捯饬得妥妥当当,然后捣鼓出一个MySQL表,再接再厉,编了个Sqoop脚本。最后,咱就让这个脚本大展身手,把数据导出溜溜的。希望这篇文章能帮助你解决这个问题!
2023-04-12 16:50:07
247
素颜如水_t
转载文章
...的点击历史 并把它们降序排列出来(只显示前6个浏览历史而且不能重复) 由于以前对javascript了解不够深入 一时间手足无措 后来经过两位高手同事的指点(对这两位同事的敬仰犹如滔滔江水连绵不绝...) 恍然大悟 豁然开朗 成功地完成了此功能的添加 首先来介绍一下javascript中关于此功能的一些对象和方法: 1. window.event对象: event代表事件的状态,例如触发event对象的元素、鼠标的位置及状态、按下的键等等。 event对象只在事件发生的过程中才有效。 2. event.srcElement: 表示该事件的发生源 通俗一点说也就是该事件被触发的地方 3. srcElement.parentNode: 表示该事件发生源的父结点 4. srcElement.tagName: 表示事件发生源的标签名 5. toUpperCase(): 大写化相应字符串的方法 基本上就是这些属性和方法,可能对于刚刚接触javascript的朋友们或者以前很少使用此类功能的朋友来说, 这些对象有些陌生,不过没关系,了解以后发现其实并不难,和javascript验证表单之类的并没有太多的不同。 下面就结合程序给大家一步一步讲解(程序难免有不合理之处,希望大家多多指正,共同进步): 第一部分:javascript纪录浏览动作 复制内容到剪贴板 代码: function glog(evt) //定义纪录鼠标点击动作的函数 { evt=evt?evt:window.event;var srcElem=(evt.target)?evt.target:evt.srcElement; try { while(srcElem.parentNode&&srcElem!=srcElem.parentNode) //以上这个语句判断鼠标动作是否发生在有效区域,防止用户的无效点击也被纪录下来 { if(srcElem.tagName&&srcElem.tagName.toUpperCase()=="A")//判断用户点击的对象是否属于链接 { linkname=srcElem.innerHTML; //取出事件发生源的名称,也就是和之间的文字,也就是链接名称哈 address=srcElem.href+"_www.achome.cn_"; //取出事件发生源的href值,也就是该链接的地址 wlink=linkname+"+"+address; //将链接名称和链接地址整合到一个变量当中 old_info=getCookie("history_info"); //从Cookies中取出以前纪录的浏览历史,该函数后面有声明 //以下程序开始判断新的浏览动作是否和已有的前6个历史重复,如果不重复则写入cookies var insert=true; if(old_info==null) //判断cookie是否为空 { insert=true; } else { var old_link=old_info.split("_www.achome.cn_"); for(var j=0;j<=5;j++) { if(old_link[j].indexOf(linkname)!=-1) insert=false; if(old_link[j]=="null") break; } } if(insert) { wlink+=getCookie("history_info"); setCookie("history_info",wlink); //写入cookie,该函数后面有声明 history_show().reload(); break; } } srcElem = srcElem.parentNode; } } catch(e){} return true; } document.οnclick=glog;//使每一次页面的点击动作都执行glog函数 第2部分:Cookies的相关函数 复制内容到剪贴板 代码: //cookie的相关函数 //读取cookie中指定的内容 function getCookieVal (offset) { var endstr = document.cookie.indexOf (";", offset); if (endstr == -1) endstr = document.cookie.length; return unescape(document.cookie.substring(offset, endstr)); } function getCookie (name) { var arg = name + "="; var alen = arg.length; var clen = document.cookie.length; var i = 0; while (i < clen) { var j = i + alen; if (document.cookie.substring(i, j) == arg) return getCookieVal (j); i = document.cookie.indexOf(" ", i) + 1; if (i == 0) break; } return null; } //将浏览动作写入cookie function setCookie (name, value) { var exp = new Date(); exp.setTime (exp.getTime()+3600000000); document.cookie = name + "=" + value + "; expires=" + exp.toGMTString(); } 第3部分:页面显示函数 复制内容到剪贴板 代码: function history_show() { var history_info=getCookie("history_info"); //取出cookie中的历史记录 var content=""; //定义一个显示变量 if(history_info!=null) { history_arg=history_info.split("_www.achome.cn_"); var i; for(i=0;i<=5;i++) { if(history_arg[i]!="null") { var wlink=history_arg[i].split("+"); content+=("↑"+""+wlink[0]+" "); } document.getElementById("history").innerHTML=content; } } else {document.getElementById("history").innerHTML="对不起,您没有任何浏览纪录";} } 代码差不多就是这些了 就为大家分析到这里 还有不足之处还请大家多多指教 下面可以运行代码查看效果 查看效果 //cookie的相关函数 function getCookieVal (offset) { var endstr = document.cookie.indexOf (";", offset); if (endstr == -1) endstr = document.cookie.length; return unescape(document.cookie.substring(offset, endstr)); } function getCookie (name) { var arg = name + "="; var alen = arg.length; var clen = document.cookie.length; var i = 0; while (i < clen) { var j = i + alen; if (document.cookie.substring(i, j) == arg) return getCookieVal (j); i = document.cookie.indexOf(" ", i) + 1; if (i == 0) break; } return null; } function setCookie (name, value) { var exp = new Date(); exp.setTime (exp.getTime()+3600000000); document.cookie = name + "=" + value + "; expires=" + exp.toGMTString(); } function glog(evt) { evt=evt?evt:window.event;var srcElem=(evt.target)?evt.target:evt.srcElement; try { while(srcElem.parentNode&&srcElem!=srcElem.parentNode) { if(srcElem.tagName&&srcElem.tagName.toUpperCase()=="A") { linkname=srcElem.innerHTML; address=srcElem.href+"_www.achome.cn_"; wlink=linkname+"+"+address; old_info=getCookie("history_info"); var insert=true; if(old_info==null) //判断cookie是否为空 { insert=true; } else { var old_link=old_info.split("_www.achome.cn_"); for(var j=0;j<=5;j++) { if(old_link[j].indexOf(linkname)!=-1) insert=false; if(old_link[j]=="null") break; } } / if(insert) //如果符合条件则重新写入数据 { wlink+=getCookie("history_info"); setCookie("history_info",wlink); history_show().reload(); break; } } srcElem = srcElem.parentNode; } } catch(e){} return true; } document.οnclick=glog; function history_show() { var history_info=getCookie("history_info"); var content=""; if(history_info!=null) { history_arg=history_info.split("_www.achome.cn_"); var i; for(i=0;i<=5;i++) { if(history_arg[i]!="null") { var wlink=history_arg[i].split("+"); content+=("↑"+""+wlink[0]+" "); } document.getElementById("history").innerHTML=content; } } else {document.getElementById("history").innerHTML="对不起,您没有任何浏览纪录";} } // JavaScript Document 浏览历史排行(只显示6个最近访问站点并且没有重复的站点出现) history_show(); 点击链接: 网站1 网站2 网站3 网站4 网站5 网站6 网站7 网站8 网站9 如果有其他疑问请登陆www.achome.cn与我联系 提示:您可以先修改部分代码再运行 本篇文章为转载内容。原文链接:https://blog.csdn.net/weixin_30611227/article/details/117818020。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-04-30 21:14:40
48
转载
转载文章
...TF-8 [API]查询商户信息与结算规则 URL地址:http://pay.lqan.cn/api.php?act=query&pid={商户ID}&sign={签名字符串} 请求参数说明: 字段名变量名必填类型示例值描述 操作类型act是Stringquery此API固定值 商户IDpid是Int1001 签名字符串sign是String67d12af9ddbe38d9c7b0931ad102ca3c签名算法与支付宝签名算法相同 返回结果: 字段名变量名类型示例值描述 返回状态码codeInt11为成功,其它值为失败 商户IDpidInt1001所创建的商户ID 商户密钥keyString(32)89unJUB8HZ54Hj7x4nUj56HN4nUzUJ8i所创建的商户密钥 商户类型typeInt1此值暂无用 商户状态activeInt11为正常,0为封禁 商户余额moneyString0.00商户所拥有的余额 结算账号accountString1070077170@qq.com结算的支付宝账号 结算姓名usernameString张三结算的支付宝姓名 满多少自动结算settle_moneyString30此值为系统预定义 手动结算手续费settle_feeString1此值为系统预定义 每笔订单分成比例money_rateString98此值为系统预定义 [API]查询结算记录 URL地址:http://pay.lqan.cn/api.php?act=settle&pid={商户ID}&sign={签名字符串} 请求参数说明: 字段名变量名必填类型示例值描述 操作类型act是Stringsettle此API固定值 商户IDpid是Int1001 签名字符串sign是String67d12af9ddbe38d9c7b0931ad102ca3c签名算法与支付宝签名算法相同 返回结果: 字段名变量名类型示例值描述 返回状态码codeInt11为成功,其它值为失败 返回信息msgString查询结算记录成功! 结算记录dataArray结算记录列表 [API]查询单个订单 URL地址:http://pay.lqan.cn/api.php?act=order&pid={商户ID}&out_trade_no={商户订单号}&sign={签名字符串} 请求参数说明: 字段名变量名必填类型示例值描述 操作类型act是Stringorder此API固定值 商户IDpid是Int1001 商户订单号out_trade_no是String20160806151343349 签名字符串sign是String67d12af9ddbe38d9c7b0931ad102ca3c签名算法与支付宝签名算法相同 返回结果: 字段名变量名类型示例值描述 返回状态码codeInt11为成功,其它值为失败 返回信息msgString查询订单号成功! 易支付订单号trade_noString2016080622555342651凉秋易支付订单号 商户订单号out_trade_noString20160806151343349商户系统内部的订单号 支付方式typeStringalipayalipay:支付宝,tenpay:财付通, qqpay:QQ钱包,wxpay:微信支付 商户IDpidInt1001发起支付的商户ID 创建订单时间addtimeString2016-08-06 22:55:52 完成交易时间endtimeString2016-08-06 22:55:52 商品名称nameStringVIP会员 商品金额moneyString1.00 支付状态statusInt01为支付成功,0为未支付 [API]批量查询订单 URL地址:http://pay.lqan.cn/api.php?act=orders&pid={商户ID}&sign={签名字符串} 请求参数说明: 字段名变量名必填类型示例值描述 操作类型act是Stringorders此API固定值 商户IDpid是Int1001 查询订单数量limit否Int20返回的订单数量,最大50 签名字符串sign是String67d12af9ddbe38d9c7b0931ad102ca3c签名算法与支付宝签名算法相同 返回结果: 字段名变量名类型示例值描述 返回状态码codeInt11为成功,其它值为失败 返回信息msgString查询结算记录成功! 订单列表dataArray订单列表 [API]支付订单退款 URL地址:http://pay.lqan.cn/api.php?act=refund&pid={商户ID}&out_trade_no={商户订单号}&sign={签名字符串} 只支持微信官方、QQ钱包官方、当面付退款 请求参数说明: 字段名变量名必填类型示例值描述 操作类型act是Stringrefund此API固定值 商户IDpid是Int1001 商户订单号out_trade_no是Int1000 退款原因desc否String 退款金额money否Double20.00不填默认退全款 签名字符串sign是String67d12af9ddbe38d9c7b0931ad102ca3c签名算法与支付宝签名算法相同 返回结果: 字段名变量名类型示例值描述 返回状态码codeInt11为成功,其它值为失败 返回信息msgString退款成功! 发起支付请求 URL地址:http://pay.lqan.cn/submit.php?pid={商户ID}&type={支付方式}&out_trade_no={商户订单号}¬ify_url={服务器异步通知地址}&return_url={页面跳转通知地址}&name={商品名称}&money={金额}&sitename={网站名称}&sign={签名字符串}&sign_type=MD5 请求参数说明: 字段名变量名必填类型示例值描述 商户IDpid是Int1001 支付方式type是Stringalipayalipay:支付宝,tenpay:财付通, qqpay:QQ钱包,wxpay:微信支付 商户订单号out_trade_no是String20160806151343349 异步通知地址notify_url是Stringhttp://域名/notify_url.php服务器异步通知地址 跳转通知地址return_url是Stringhttp://域名/return_url.php页面跳转通知地址 商品名称name是StringVIP会员 商品金额money是String1.00 网站名称sitename否String某某某平台 签名字符串sign是String202cb962ac59075b964b07152d234b70签名算法与支付宝签名算法相同 签名类型sign_type是StringMD5默认为MD5 支付结果通知 通知类型:服务器异步通知(notify_url)、页面跳转通知(return_url) 请求方式:GET 特别说明:回调成功之后请输出 SUCCESS字符串,如果没有收到商户响应的SUCCESS字符串,系统将通过策略重新通知5次,通知频率为15s/60s/3m/30m/1h 请求参数说明: 字段名变量名必填类型示例值描述 商户IDpid是Int1001 易支付订单号trade_no是String20160806151343349021凉秋易支付订单号 商户订单号out_trade_no是String20160806151343349商户系统内部的订单号 支付方式type是Stringalipayalipay:支付宝,tenpay:财付通, qqpay:QQ钱包,wxpay:微信支付 商品名称name是StringVIP会员 商品金额money是String1.00 支付状态trade_status是StringTRADE_SUCCESS 签名字符串sign是String202cb962ac59075b964b07152d234b70签名算法与支付宝签名算法相同 签名类型sign_type是StringMD5默认为MD5 签名算法 请对参数按照键名进行降序排序(a-z)sign sign_type 和空值不进行签名!。 排序后请操作参数生成或拼接一个url请求字符串 例如 a=b&c=d&e=f (Url值不能携带参数!不要进行urlencode) 再将拼接好的请求字符串与平台生成的Key进行MD5加密得出sign签名参数 MD5 ( a=b&c=d&e=f + KEY ) (注意:+ 为各语言的拼接符!不是字符!) 本篇文章为转载内容。原文链接:https://blog.csdn.net/weixin_39620334/article/details/115933932。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-12-18 16:55:58
91
转载
Spark
...是一种高级抽象,用于查询关系表。就像Dataframe API那样,Spark SQL也给我们带来了一种超级实用又高效的处理小文件的方法,一点儿也不复杂,特别接地气儿。Spark SQL还自带了一堆超级实用的内置函数,比如COUNT、SUM、AVG这些小帮手,用它们来处理小文件,那速度可真是嗖嗖的,轻松又高效。 下面是一个简单的例子,展示如何使用Spark SQL来读取小文件: scss val df = spark.sql("SELECT FROM /path/to/files/") 在这个例子中,我们使用sql函数来执行SQL语句,从而从指定目录下读取CSV文件并转化为DataFrame。 3. 使用Partitioner Partitioner是Spark的一种内置机制,用于将数据分割成多个块。当我们处理大量小文件时,可以使用Partitioner来提高处理效率。其实呢,我们可以这样来操作:比如说,按照文件的名字呀,或者文件里边的内容这些规则,把那些小文件分门别类地整理一下。就像是给不同的玩具放在不同的抽屉里一样,每个类别都单独放到一个文件夹里面去存储,这样一来就清清楚楚、井井有条啦!这样一来,每次我们要读取文件的时候,就只需要瞄一眼一个文件夹里的内容,压根不需要把整个目录下的所有文件都翻个底朝天。 下面是一个简单的例子,展示如何使用Partitioner来处理小文件: python val partitioner = new HashPartitioner(5) val rdd = sc.textFile("/path/to/files/") .map(line => (line.split(",").head, line)) .partitionBy(partitioner) val output = rdd.saveAsTextFile("/path/to/output/") 在这个例子中,我们首先使用textFile函数从指定目录下读取文本文件,并将其转化为RDD。接着,我们运用一个叫做map的神奇小工具,就像魔法师挥动魔杖那样,把每一行文本巧妙地一分为二,一部分是文件名,另一部分则是内容。然后,我们采用了一个叫做partitionBy的神奇函数,就像把RDD里的数据放进不同的小篮子里那样,按照文件名给它们分门别类。这样一来,每个“篮子”里都恰好装了5个小文件,整整齐齐,清清楚楚。最后,我们使用saveAsTextFile函数将RDD保存为文本文件。因为我们已经按照文件名把文件分门别类地放进不同的“小桶”里了,所以现在每次找文件读取的时候,就不用像无头苍蝇一样满目录地乱窜,只需要轻轻松松打开一个文件夹,就能找到我们需要的文件啦! 四、结论 通过以上三种方法,我们可以有效地优化Spark在读取大量小文件时的性能。Dataframe API和Spark SQL提供了简单且高效的API,可以快速处理结构化数据。Partitioner这个小家伙,就像个超级有条理的文件整理员,它能够按照特定的规则,麻利地把那些小文件分门别类放好。这样一来,当你需要读取文件的时候,就仿佛拥有了超能力一般,嗖嗖地提升读取速度,让效率飞起来!当然啦,这只是入门级别的小窍门,真正要让方案火力全开,还得瞅准实际情况灵活变通,不断打磨和优化才行。
2023-09-19 23:31:34
45
清风徐来-t
MySQL
... 这条SQL语句会返回当前MySQL服务器所在的主机名。如果你想进一步验证是不是本地环境,可以再试试: sql SELECT @@datadir; 这段代码会显示MySQL的数据目录路径。要是文件路径里提到你的用户名,或者用的是系统盘符(像 C:\ProgramData\MySQL\MySQL Server 8.0\Data 这种),那十有八九数据库就在你自己的电脑上啦! --- 情况二:数据库运行在远程服务器上 如果你的MySQL数据库部署在一台远程服务器上,那么它的IP地址就不会是localhost了。你需要通过一些工具或者命令来获取具体的IP地址。 方法一:直接登录服务器查看 假设你有一台Linux服务器,可以通过SSH工具(比如PuTTY或终端)登录到服务器后,执行以下命令: bash ifconfig | grep "inet " 这段命令会列出服务器的所有网络接口及其对应的IP地址。如果你看到类似inet 192.168.1.100这样的输出,恭喜你,这就是MySQL数据库所在服务器的IP地址啦! 方法二:通过MySQL命令查看 如果你已经成功连接到了远程MySQL服务器,也可以在MySQL客户端中执行以下命令: sql SELECT @@hostname; 这条命令同样会返回数据库所在的主机名。不过,这里得到的通常是服务器的域名(比如myserver.example.com)。为了找到真实的IP地址,你可以使用ping命令进行测试: bash ping myserver.example.com 通过这种方式,你可以轻松地将域名解析为实际的IP地址。 --- 2. MySQL配置文件中的IP地址 有时候,数据库的IP地址并不是动态分配的,而是明确写在了配置文件里。这种情况下,我们只需要找到配置文件的位置并读取它即可。 配置文件在哪里? 不同的操作系统和安装方式可能会导致配置文件的位置有所不同。以下是常见的几个位置: - Linux/Unix系统:通常是/etc/mysql/my.cnf或者/etc/my.cnf。 - Windows系统:可能是C:\ProgramData\MySQL\MySQL Server 8.0\my.ini。 - macOS:可以尝试查找/usr/local/mysql/my.cnf。 打开配置文件后,搜索关键词bind-address。这个参数定义了MySQL服务监听的IP地址。例如: ini bind-address = 192.168.1.100 这里的192.168.1.100就是MySQL数据库的IP地址。如果该值为空,则表示MySQL监听所有可用的IP地址。 --- 3. 使用第三方工具检测数据库IP 如果你没有权限直接访问服务器或者配置文件,还可以借助一些第三方工具来探测数据库的IP地址。 工具推荐: 1. Nmap 一款强大的网络扫描工具,可以帮助你发现目标服务器上的开放端口和服务。 bash nmap -p 3306 yourdomain.com 如果MySQL服务正在运行并且监听了外部请求,那么这段命令会显示出相应的IP地址。 2. telnet 一种简单的远程连接工具,用于检查特定端口是否可达。 bash telnet yourdomain.com 3306 如果连接成功,说明MySQL服务正在指定的IP地址上运行。 --- 4. 小结与反思 经过一番折腾,我们终于找到了MySQL数据库的IP地址。虽然过程有些曲折,但我相信这些方法对大家来说都非常实用。在这个过程中,我也学到了很多新东西,比如如何解读配置文件、如何利用命令行工具解决问题等等。 最后想提醒大家一句:无论你是新手还是老鸟,在操作数据库时都要小心谨慎,尤其是在涉及网络配置的时候。毕竟,稍不留神就可能导致数据泄露或者其他严重后果。所以,动手之前一定要三思而后行哦! 好了,今天的分享就到这里啦!如果你还有什么疑问或者更好的解决方案,欢迎随时留言交流。咱们下期再见!
2025-03-24 15:46:41
78
笑傲江湖
转载文章
...据库将被导出。 通过执行mysqldump --help,你能得到你mysqldump的版本支持的选项表。 注意,如果你运行mysqldump没有--quick或--opt选项,mysqldump将在导出结果前装载整个结果集到内存中,如果你正在导出一个大的数据库,这将可能是一个问题。 mysqldump支持下列选项: --add-locks 在每个表导出之前增加LOCK TABLES并且之后UNLOCK TABLE。(为了使得更快地插入到MySQL)。 --add-drop-table 在每个create语句之前增加一个drop table。 --allow-keywords 允许创建是关键词的列名字。这由表名前缀于每个列名做到。 -c, --complete-insert 使用完整的insert语句(用列名字)。 -C, --compress 如果客户和服务器均支持压缩,压缩两者间所有的信息。 --delayed 用INSERT DELAYED命令插入行。 -e, --extended-insert 使用全新多行INSERT语法。(给出更紧缩并且更快的插入语句) -, --debug[=option_string] 跟踪程序的使用(为了调试)。 --help 显示一条帮助消息并且退出。 --fields-terminated-by=... --fields-enclosed-by=... --fields-optionally-enclosed-by=... --fields-escaped-by=... --fields-terminated-by=... 这些选择与-T选择一起使用,并且有相应的LOAD DATA INFILE子句相同的含义。 LOAD DATA INFILE语法。 -F, --flush-logs 在开始导出前,洗掉在MySQL服务器中的日志文件。 -f, --force, 即使我们在一个表导出期间得到一个SQL错误,继续。 -h, --host=.. 从命名的主机上的MySQL服务器导出数据。缺省主机是localhost。 -l, --lock-tables. 为开始导出锁定所有表。 -t, --no-create-info 不写入表创建信息(CREATE TABLE语句) -d, --no-data 不写入表的任何行信息。如果你只想得到一个表的结构的导出,这是很有用的! --opt 同--quick --add-drop-table --add-locks --extended-insert --lock-tables。 应该给你为读入一个MySQL服务器的尽可能最快的导出。 -pyour_pass, --password[=your_pass] 与服务器连接时使用的口令。如果你不指定“=your_pass”部分,mysqldump需要来自终端的口令。 -P port_num, --port=port_num 与一台主机连接时使用的TCP/IP端口号。(这用于连接到localhost以外的主机,因为它使用 Unix套接字。) -q, --quick 不缓冲查询,直接导出至stdout;使用mysql_use_result()做它。 -S /path/to/socket, --socket=/path/to/socket 与localhost连接时(它是缺省主机)使用的套接字文件。 -T, --tab=path-to-some-directory 对于每个给定的表,创建一个table_name.sql文件,它包含SQL CREATE 命令,和一个table_name.txt文件,它包含数据。 注意:这只有在mysqldump运行在mysqld守护进程运行的同一台机器上的时候才工作。.txt文件的格式根据--fields-xxx和--lines--xxx选项来定。 -u user_name, --user=user_name 与服务器连接时,MySQL使用的用户名。缺省值是你的Unix登录名。 -O var=option, --set-variable var=option设置一个变量的值。可能的变量被列在下面。 -v, --verbose 冗长模式。打印出程序所做的更多的信息。 -V, --version 打印版本信息并且退出。 -w, --where=@where-condition@ 只导出被选择了的记录;注意引号是强制的! "--where=user=@jimf@" "-wuserid>1" "-wuserid<1" 最常见的mysqldump使用可能制作整个数据库的一个备份: mysqldump --opt database > backup-file.sql 但是它对用来自于一个数据库的信息充实另外一个MySQL数据库也是有用的: mysqldump --opt database | mysql --host=remote-host -C database 由于mysqldump导出的是完整的SQL语句,所以用mysql客户程序很容易就能把数据导入了: shell> mysqladmin create target_db_name shell> mysql target_db_name < backup-file.sql 就是 shell> mysql 库名 < 文件名 相关标签:工具 本文原创发布php中文网,转载请注明出处,感谢您的尊重! 本篇文章为转载内容。原文链接:https://blog.csdn.net/weixin_28851659/article/details/114329359。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-02-01 23:51:06
265
转载
SpringBoot
Oracle查询超时问题:Spring Boot与Druid集成场景? 1. 引子 我的困惑之旅 作为一个刚入行不久的Java开发工程师,我最近在负责一个基于Spring Boot的项目。这个项目需要与Oracle数据库交互,而我选用了Druid作为数据源管理工具。事情本来挺顺的,大家都觉得没啥问题,结果有一天,我们的系统突然蹦出个消息,说啥“查询超时”!就那么一下,气氛瞬间紧张了,感觉空气都凝固了似的。 当时我整个人都懵了——这到底是什么情况?是Oracle的问题吗?还是Spring Boot的锅?或者是我对Druid的理解还不够深入?带着这些疑问,我开始了一段探索之旅。今天,我想把这段经历分享给大家,希望能帮助那些和我一样遇到类似问题的朋友。 --- 2. 什么是“查询超时”? 简单来说,“查询超时”就是你的SQL语句执行的时间超过了设定的最大允许时间,导致系统直接抛出异常。哎呀,这种情况在实际开发里真的挺常见的,特别是那种高并发的场景。你要是数据库连接池没配好,那问题就容易冒出来了,简直防不胜防! 对于我来说,这个问题尤其令人头疼,因为我们的项目依赖于Oracle数据库,而Oracle本身就是一个功能强大的关系型数据库,但同时也有一些“坑”。比如说啊,它的默认查询超时时间可能设得有点短,要是咱们不改一下这个设置,那查询的时候就容易卡壳儿,最后连结果都拿不到。 --- 3. Spring Boot与Druid集成的基本配置 首先,让我们回顾一下如何在Spring Boot项目中集成Druid。这是一个非常基础的操作,但也是解决问题的第一步。 3.1 添加依赖 在pom.xml文件中添加Druid的相关依赖: xml com.alibaba druid-spring-boot-starter 1.2.8 3.2 配置数据源 接着,在application.yml文件中配置Druid的数据源信息: yaml spring: datasource: type: com.alibaba.druid.pool.DruidDataSource driver-class-name: oracle.jdbc.driver.OracleDriver url: jdbc:oracle:thin:@localhost:1521:orcl username: your_username password: your_password druid: initial-size: 5 max-active: 20 min-idle: 5 max-wait: 60000 time-between-eviction-runs-millis: 60000 min-evictable-idle-time-millis: 300000 validation-query: SELECT 1 FROM DUAL test-while-idle: true test-on-borrow: false test-on-return: false 这段配置看似简单,但实际上每一项参数都需要仔细斟酌。比如说啊,“max-wait”这个参数呢,就是说咱们能等连接连上的最长时间,单位是毫秒,相当于给它设了个“最长等待时间”;然后还有个“validation-query”,这个名字听起来就挺专业的,它的作用就是检查连接是不是还正常好用;最后那个“test-while-idle”,它就像是个“巡逻兵”,负责判断要不要在连接空闲的时候去检测一下这条连接还能不能用。 --- 4. 查询超时问题的初步排查 当我第一次遇到查询超时问题时,我的第一反应是:是不是Oracle那边的SQL语句太慢了?于是,我开始检查SQL语句的性能。 4.1 检查SQL语句 我用PL/SQL Developer连接到Oracle数据库,运行了一下报错的SQL语句。结果显示,这条SQL语句确实需要花费较长时间才能完成。但问题是,为什么Spring Boot会直接抛出超时异常呢? 这时,我才意识到,可能是Druid的数据源配置有问题。于是我翻阅了Druid的官方文档,发现了一个关键点:Druid默认的查询超时时间为10秒。 4.2 修改Druid的查询超时时间 为了延长查询超时时间,我在application.yml中加入了以下配置: yaml spring: datasource: druid: query-timeout: 30000 这里的query-timeout参数就是用来设置查询超时时间的,单位是毫秒。经过这次调整后,我发现查询超时的问题暂时得到了缓解。 --- 5. 进一步优化 结合Oracle的设置 虽然Druid的配置解决了部分问题,但我仍然觉得不够完美。于是,我又转向了Oracle数据库本身的设置。 5.1 设置Oracle的查询超时 在Oracle中,可以通过设置statement_timeout参数来控制查询超时时间。这个参数可以在会话级别或全局级别进行设置。 例如,在Spring Boot项目中,我们可以通过JDBC连接字符串传递这个参数: yaml spring: datasource: url: jdbc:oracle:thin:@localhost:1521:orcl?oracle.net.CONNECT_TIMEOUT=30000&oracle.jdbc.ReadTimeout=30000 这里的CONNECT_TIMEOUT和ReadTimeout分别表示连接超时时间和读取超时时间。通过这种方式,我们可以进一步提高系统的容错能力。 --- 6. 我的感悟与总结 经过这次折腾,我对Spring Boot与Druid的集成有了更深的理解。说实话,好多技术难题没那么玄乎,就是看着吓人而已。只要你肯静下心来琢磨琢磨,肯定能想出个辙来! 在这里,我也想给新手朋友们一些建议: 1. 多看官方文档 无论是Spring Boot还是Druid,它们的官方文档都非常详细,很多时候答案就在那里。 2. 学会调试 遇到问题时,不要急于求解,先用调试工具一步步分析问题所在。 3. 保持耐心 技术问题往往需要反复尝试,不要轻易放弃。 最后,我想说的是,编程之路充满了挑战,但也正因为如此才显得有趣。希望大家都能在这个过程中找到属于自己的乐趣! --- 好了,这篇文章就到这里啦!如果你也有类似的经历或想法,欢迎在评论区跟我交流哦!
2025-04-21 15:34:10
39
冬日暖阳_
转载文章
...查的语法,跨表的连接查询等。网上找一个例子,如可以自己构建一个学生课程信息表,做到可以用以上学习到的语法。 学习完数据库,接着我们就需要学习Java JDBC 的知识。学习的 JDBC 就是让我们了解,如何使用 Java 操作数据库,运行 Mybatis的增删改查的语句。 接着我们可以去学习相关 ORM 的框架,如 Hibernate 或 Mybatis,这里推荐 Mybatis。学习框架,我们要做到掌握框架的使用技巧就可以。 这个过程你可能会发现,Mybatis 这类框架这么如此简化开发,为什么我们不直接学习 Mybatis ? 学习 JDBC 的目的,其实就是让你了解这些 ORM 的基础。 学完这个阶段,我们接下去就要进入 WEB 开发。 WEB 开发 这个过程我们首先学习一些前端知识,如 HTML,CSS,JavaScript,然后再去 Jquery 等前端框架,做到能实现一些简单的功能。我们不需要跟你上面一样精通,我们只要了解一些概念即可。 接下去我们学习 Servlet,做到能使用原生 Servlet + Jsp 能运行一个 WEB 程序。 后面我们再去学习 Spring 框架,使用 SpringMVC 了解 MVC 的概念。最后用 SpringMVC+Spring+Mybatis+MySQL 完成一个简单的管理系统。 其他 学完以上内容,基本上已经学习完工作中学习到的技术栈。这个过程你还需要额外学习一些工作中用到其他知识。 你需要去学习协同开发的工具,如 Git,SVN。做到了解如何新建分支,如何拉取代码,如何合并代码即可。 你还需要去学习一些 Linux 的命令。 总结 学完上述内容,你实际就已经掌握初级开发所需要的技术,已经基本上可以从事一个初级开发的岗位。我们上面讲的都是使用技巧,但是面试的时候可能会问你一些原理性的内容,所以在我们去找工作之前我们还需要去了解一些原理性知识。这方面的内容通过搜索引擎搜索即可。 这个过程你可能会碰到很多问题,这个过程一定善于使用搜索引擎。 本篇文章为转载内容。原文链接:https://blog.csdn.net/qq_35006660/article/details/115610534。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-07-02 23:59:06
60
转载
Hive
...——把你的 SQL 查询语句给翻译成 MapReduce 任务,然后甩给 Hadoop 去干活儿。而HDFS呢,就是存储这些数据的地方。它们就像一对老朋友,互相依赖,缺一不可。 但有时候,这俩家伙可能会闹别扭,尤其是当你发现Hive突然不能访问HDFS了。这可真是让人头疼,因为这意味着你的数据查询直接凉凉。所以今天我们就来聊聊,为什么会出现这种情况,以及该怎么解决。 二、可能的原因 为什么Hive访问不了HDFS? 2.1 网络问题 首先,我们得想想是不是网络出了问题。嘿,你知道吗?我猜你们公司那位网络大神最近是不是偷偷调整了防火墙的设置?或者是服务器那边抽风了,直接断网了?反正不管咋回事儿,现在Hive跟HDFS就像是隔了一座大山,怎么也连不上,所以它想读数据都读不到啊! 举个例子吧,假设你的Hive配置文件里写着HDFS的地址是hdfs://namenode:9000/,但是实际上NameNode所在的机器根本不在网络范围内,那Hive当然会报错啦。 解决方法:检查一下网络连接是否正常。你可以试着ping一下HDFS的NameNode地址,看看能不能通。如果不行的话,赶紧找网络管理员帮忙修一下。 2.2 权限问题 其次,权限问题也是常见的原因。HDFS对文件和目录是有严格权限控制的,如果你的用户没有足够的权限去读取某个文件,那么Hive自然也无能为力。 举个栗子,假如你有一个HDFS路径/user/hive/warehouse/my_table,但是这个目录的权限设置成了只有root用户才能访问,而你的Hive用户不是root,那肯定就悲剧了。 解决方法:检查HDFS上的文件和目录权限。如果你想看看某个文件的权限,可以用这个命令:hadoop fs -ls /path/to/file。看完之后,要是觉得权限不对劲,就动手改一下呗,比如说用hadoop fs -chmod 755 /path/to/file,给它整成合适的权限就行啦! 2.3 HDFS服务未运行 还有一种可能是HDFS服务本身挂掉了。比如说,NameNode突然罢工了,DataNode也闹起了情绪,甚至整个集群都瘫痪了,啥都不干了。哎呀糟糕了,这情况有点悬啊!HDFS直接罢工了,完全不干活,任凭Hive使出浑身解数也无济于事。这下可好,整个系统像是瘫了一样,啥也跑不起来了。 解决方法:检查HDFS的服务状态。可以通过命令jps查看是否有NameNode和DataNode进程在运行。如果没有,那就得赶紧启动它们,或者重启整个HDFS服务。 三、实战演练 Hive访问HDFS的具体操作 接下来,我们通过一些实际的例子来看看如何用Hive操作HDFS。 3.1 创建表并加载数据到HDFS 假设我们现在要创建一个简单的表,并将数据加载到HDFS中。我们可以先创建一个本地文件data.txt,内容如下: id,name,age 1,Alice,25 2,Bob,30 3,Charlie,35 然后上传到HDFS: bash hadoop fs -put data.txt /user/hive/warehouse/my_table/ 接着在Hive中创建表: sql CREATE TABLE my_table ( id INT, name STRING, age INT ) ROW FORMAT DELIMITED FIELDS TERMINATED BY ',' STORED AS TEXTFILE; 最后加载数据: sql LOAD DATA INPATH '/user/hive/warehouse/my_table/data.txt' INTO TABLE my_table; 这样,我们的数据就成功存到了HDFS上,并且Hive也能读取到了。 3.2 查询数据 现在我们可以试试查询数据: sql SELECT FROM my_table; 如果一切正常,你应该能看到类似这样的结果: OK 1 Alice 25 2 Bob 30 3 Charlie 35 Time taken: 0.077 seconds, Fetched: 3 row(s) 但如果之前出现了访问不了HDFS的情况,这里就会报错。所以我们要确保每一步都正确无误。 四、总结与展望 总之,Hive无法访问HDFS的问题虽然看起来很复杂,但实际上只要找到根本原因,解决起来并不难。无论是网络问题、权限问题还是服务问题,都有相应的解决办法。嘿,大家听我说啊!以后要是再碰到这种事儿,别害怕,也别乱了阵脚。就当是玩个解谜游戏,一步一步慢慢来,肯定能找出办法搞定它! 未来,随着大数据技术的发展,Hive和HDFS的功能也会越来越强大。说不定哪天它们还能像人类一样交流感情呢!(开玩笑啦) 好了,今天的分享就到这里啦。如果你还有什么疑问或者经验想要分享,欢迎随时留言讨论哦!让我们一起进步,一起探索大数据的奥秘吧!
2025-04-01 16:11:37
105
幽谷听泉
转载文章
...Java程序与SQL语句,简化了数据访问操作,实现了数据的增删改查等功能。 Spring Framework , Spring是一个开源的企业级Java应用程序框架,文中使用的版本是Spring-4.0.0。Spring以其控制反转(IoC)和面向切面编程(AOP)等特性著称,能帮助开发者构建高质量、松耦合的应用系统。在该项目中,Spring负责管理和整合各组件,如数据源配置、事务管理以及集成Mybatis实现业务逻辑层的功能。 DAO(Data Access Object)接口 , 在软件开发领域,DAO是一种设计模式,常用于将底层的数据访问细节与业务逻辑分离。在本文中,创建的UserMapper.java文件就是一个DAO接口示例,定义了一系列与用户表t_user相关的CRUD操作方法,如保存(save)、更新(update)、删除(delete)、按ID查找(findById)以及查询所有用户信息(findAll)。通过这种方式,业务层代码只需调用这些接口方法即可进行数据库操作,无需关心具体的SQL执行细节。 XML映射文件 , 在Mybatis框架中,XML映射文件用于描述SQL语句以及SQL结果如何映射到Java对象上。例如,UserMapper.xml文件就是对UserMapper.java接口中的方法对应的SQL实现,每个方法对应一个SQL片段,并通过 参数名 的方式引用Java方法传递过来的参数,确保SQL执行时能够动态绑定参数值,同时也提供了处理结果集映射到Java对象的方法,实现了ORM(对象关系映射)功能。
2023-09-05 11:56:25
111
转载
Kylin
...合得天衣无缝,让数据查询快如闪电,用户体验棒棒哒!这背后涉及到的技术细节可多了去了,比如索引优化、查询语句的编写技巧,还有就是数据库配置的调整,每一步都得精心设计,才能让整个系统运行得既高效又稳定。所以,这不仅仅是个理论问题,更是一场实战演练,考验的是咱们对数据库知识的掌握和运用能力呢!本文将带你一起揭开这个谜题的面纱,从理论到实践,全方位解析Kylin与MySQL联接优化的关键点。 二、理论基础 理解Kylin与MySQL的联接机制 在深入讨论优化策略之前,我们首先需要理解两者之间的基本联接机制。Kylin是一个基于Hadoop的列式存储OLAP引擎,它通过预先计算并存储聚合数据来加速查询速度。而MySQL作为一个广泛使用的SQL数据库管理系统,提供了丰富的查询语言和存储能力。嘿,兄弟!你听过数据联接这事儿吗?它通常在咱们把数据从一个地方搬进另一个地方或者在查询数据的时候出现。就像拼图一样,对了,就是那种需要精准匹配才能完美组合起来的拼图。用对了联接策略,那操作效率简直能嗖的一下上去,比火箭还快呢!所以啊,小伙伴们,别小瞧了这个小小的联接步骤,它可是咱们大数据处理里的秘密武器! 三、策略一 优化联接条件 实践示例: sql -- 原始查询语句 SELECT FROM kylin_table JOIN mysql_table ON kylin_table.id = mysql_table.id; -- 优化后的查询语句 SELECT FROM kylin_table JOIN mysql_table ON kylin_table.id = mysql_table.id AND kylin_table.date >= '2023-01-01' AND kylin_table.date <= '2023-12-31'; 通过在联接条件中加入过滤条件(如时间范围),可以减少MySQL服务器需要处理的数据量,从而提高联接效率。 四、策略二 利用索引优化 实践示例: 在MySQL表上为联接字段创建索引,可以大大加速查询速度。同时,在Kylin中,确保相关维度的列已经进行了适当的索引,可以进一步提升性能。 sql -- MySQL创建索引 CREATE INDEX idx_kylin_table_id ON kylin_table(id); -- Kylin配置维度索引 id long true 通过这样的配置,不仅MySQL的查询速度得到提升,Kylin的聚合计算也更加高效。 五、策略三 批量导入与增量更新 实践示例: 对于大型数据集,考虑使用批量导入策略,而不是频繁的增量更新。哎呀,你瞧,咱们用批量导入这招,就像是给MySQL服务器做了一次减压操,让它不那么忙碌,喘口气。同时,借助Kylin的离线大法,我们就能让那些实时查询快如闪电,不拖泥带水。这样一来,不管是数据处理还是查询速度,都大大提升了,用户满意度也蹭蹭往上涨呢! bash 批量导入脚本示例 $ hadoop fs -put data.csv /input/ $ bin/hive -e "LOAD DATA INPATH '/input/data.csv' INTO TABLE kylin_table;" 六、策略四 优化联接模式 选择合适的联接模式(如内联接、外联接等)对于性能优化至关重要。哎呀,你得知道,在咱们实际干活的时候,选对了数据联接的方式,就像找到了开锁的金钥匙,能省下不少力气,避免那些没必要的数据大扫荡。比如说,你要是搞个报表啥的,用对了联接方法,数据就乖乖听话,找起来快又准,省得咱们一个个文件翻,一个个字段找,那得多费劲啊!所以,挑对工具,效率就是王道! 实践示例: 假设我们需要查询所有在特定时间段内的订单信息,并且关联了用户的基本信息。这里,我们可以使用内联接: sql SELECT FROM orders o INNER JOIN users u ON o.user_id = u.user_id WHERE o.order_date BETWEEN '2023-01-01' AND '2023-12-31'; 七、总结与展望 通过上述策略的实施,我们能够显著提升Kylin与MySQL联接操作的性能。哎呀,你知道优化数据库操作这事儿,可真是个门道多得很!比如说,调整联接条件啊,用上索引来提速啊,批量导入数据也是一大妙招,还有就是选对联接方式,这些小技巧都能让咱们的操作变得顺畅无比,响应速度嗖嗖的快起来。就像开车走高速,不堵车不绕弯,直奔目的地,那感觉,爽歪歪!哎呀,随着咱手里的数据越来越多,就像超市里的货物堆积如山,技术这玩意儿也跟咱们的手机更新换代一样快。所以啊,要想让咱们的系统运行得又快又好,就得不断调整和改进策略。就像是给汽车定期加油、保养,让它跑得既省油又稳定。这事儿,可得用心琢磨,不能偷懒!未来,随着更多高级特性如分布式计算、机器学习集成等的引入,Kylin与MySQL的联接优化将拥有更广阔的应用空间,助力数据分析迈向更高层次。
2024-09-20 16:04:27
104
百转千回
MySQL
...t用户的权限,可以执行以下命令: sql SHOW GRANTS FOR 'root'@'localhost'; 这个命令会返回root用户在localhost上的所有权限。比如: plaintext GRANT ALL PRIVILEGES ON . TO 'root'@'localhost' WITH GRANT OPTION 这里的ALL PRIVILEGES表示root用户拥有所有的权限,包括对所有数据库和表的操作权限。WITH GRANT OPTION表示该用户还可以将这些权限授予其他用户。 但是,有时候我们会忘记具体设置了哪些权限,这时候就需要手动检查了。我们可以用SELECT语句查询mysql.user表来查看详细信息: sql SELECT FROM mysql.user WHERE User='root'; 这个查询会返回root用户的详细权限设置,包括是否允许登录、是否有超级权限等。 四、查看特定数据库的权限 接下来,我们来看如何查看特定数据库的权限。假设我们有一个名为my_database的数据库,想看看这个数据库的所有表的权限,可以使用SHOW GRANTS命令结合具体的数据库名: sql SHOW GRANTS FOR 'some_user'@'%' ON my_database.; 这里的some_user是我们要检查的用户,%表示可以从任何主机连接。ON my_database.表示只查看my_database数据库中的权限。 如果想看更详细的权限设置,可以通过查询mysql.db表来实现: sql SELECT FROM mysql.db WHERE Db='my_database'; 这个查询会返回my_database数据库的所有权限设置,包括用户、权限类型(如SELECT、INSERT、UPDATE等)以及允许的主机。 五、查看特定表的权限 现在,我们已经知道了如何查看整个数据库的权限,那么接下来就是查看特定表的权限了。MySQL里有个SHOW TABLE STATUS的命令,能让我们瞅一眼某个表的基本情况,比如它有多大、创建时间啥的。不过呢,要是想看权限相关的东西,还得再折腾一下才行。 假设我们有一个表叫users,想要查看这个表的权限,可以这样做: sql SHOW GRANTS FOR 'some_user'@'%' ON my_database.users; 这条命令会显示some_user用户在my_database数据库的users表上的所有权限。如果你觉得这样还不够直观,可以查询information_schema.TABLE_PRIVILEGES视图: sql SELECT FROM information_schema.TABLE_PRIVILEGES WHERE TABLE_SCHEMA='my_database' AND TABLE_NAME='users'; 这个查询会返回my_database数据库中users表的所有权限记录,包括权限类型、授权用户等信息。 六、实战演练 批量检查所有表的权限 在实际工作中,我们可能需要批量检查整个数据库中所有表的权限。其实MySQL本身没给个现成的命令能一口气看看所有表的权限,不过咱们可以用脚本自己搞掂啊! 下面是一个简单的Python脚本示例,用来遍历数据库中的所有表并打印它们的权限: python import pymysql 连接到MySQL服务器 conn = pymysql.connect(host='localhost', user='root', password='your_password') cursor = conn.cursor() 获取数据库列表 cursor.execute("SHOW DATABASES") databases = cursor.fetchall() for db in databases: db_name = db[0] 跳过系统数据库 if db_name in ['information_schema', 'performance_schema', 'mysql']: continue 切换到当前数据库 cursor.execute(f"USE {db_name}") 获取表列表 cursor.execute("SHOW TABLES") tables = cursor.fetchall() for table in tables: table_name = table[0] 查询表的权限 cursor.execute(f"SHOW GRANTS FOR 'some_user'@'%' ON {db_name}.{table_name}") grants = cursor.fetchall() print(f"Database: {db_name}, Table: {table_name}") for grant in grants: print(grant) 关闭连接 cursor.close() conn.close() 这个脚本会连接到你的MySQL服务器,依次检查每个数据库中的所有表,并打印出它们的权限设置。你可以根据需要修改脚本中的用户名和密码。 七、总结与思考 通过这篇文章,我们学习了如何查看MySQL中所有表的权限。从最高级别的全局权限,到某个数据库的权限,再细化到某张表的权限,每个环节都有一套对应的命令和操作方法,就跟搭积木一样,一层层往下细分,但每一步都有章可循!MySQL的权限管理系统确实有点复杂,感觉像是个超级强大的工具箱,里面的东西又多又专业。不过别担心,只要你搞清楚了最基本的那些“钥匙”和“门道”,基本上就能搞定各种情况啦,就跟玩闯关游戏一样,熟悉了规则就没什么好怕的! 在这个过程中,我一直在思考一个问题:为什么MySQL要设计这么复杂的权限系统?其实答案很简单,因为安全永远是第一位的。无论是企业级应用还是个人项目,我们都不能忽视权限管理的重要性。希望能通过这篇文章,让你在实际操作中更轻松地搞懂MySQL的权限系统,用起来也更得心应手! 最后,如果你还有其他关于权限管理的问题,欢迎随时交流!咱们一起探索数据库的奥秘!
2025-03-18 16:17:13
50
半夏微凉
转载文章
...ll_name 内的执行代码。 这个时候,同志们可以去思考下 getter() , setter() ,以及 deleter() 的具体运行机制了=。=如果还是有问题,欢迎在评论里进行讨论。 关于描述符 还记得之前我们所提到的一个定义么: Descriptors 是一种特殊的对象,这种对象实现了 __get__ , __set__ , __delete__ 这三个特殊方法 。然后在 Python 官方文档的说明中,为了体现描述符的重要性,有这样一段话:“They are the mechanism behind properties, methods, static methods, class methods, and super(). They are used throughout Python itself to implement the new style classes introduced in version 2.2. ” 简而言之就是 先有描述符后有天,秒天秒地秒空气 。恩,在新式类中,属性,方法调用,静态方法,类方法等都是基于描述符的特定使用。 OK,你可能想问,为什么描述符是这么重要呢?别急,我们接着看 使用描述符 首先请看下一段代码 classA(object):注:在 Python 3.x 版本中,对于 new class 的使用不需要显式的指定从 object 类进行继承,如果在 Python 2.X(x>2)的版本中则需要defa(self): pass if__name__=="__main__": a=A() a.a() 大家都注意到了我们存在着这样一个语句 a.a() ,好的,现在请大家思考下,我们在调用这个方法的时候发生了什么? OK?想出来了么?没有?好的我们继续 首先我们调用一个属性的时候,不管是成员还是方法,我们都会触发这样一个方法用于调用属性 __getattribute__() ,在我们的 __getattribute__() 方法中,如果我们尝试调用的属性实现了我们的描述符协议,那么会产生这样一个调用过程 type(a).__dict__['a'].__get__(b,type(b)) 。好的这里我们又要给出一个结论了:“在这样一个调用过程中,有这样一个优先级顺序,如果我们所尝试调用属性是一个 data descriptors ,那么不管这个属性是否存在我们的实例的 __dict__ 字典中,优先调用我们描述符里的 __get__ 方法,如果我们所尝试调用属性是一个 non data descriptors ,那么我们优先调用我们实例里的 __dict__ 里的存在的属性,如果不存在,则依照相应原则往上查找我们类,父类中的 __dict__ 中所包含的属性,一旦属性存在,则调用 __get__ 方法,如果不存在则调用 __getattr__() 方法”。理解起来有点抽象?没事,我们马上会讲,不过在这里,我们先要解释下 data descriptors 与 non data descriptors ,再来看一个例子。什么是 data descriptors 与 non data descriptors 呢?其实很简单,在描述符中同时实现了 __get__ 与 __set__ 协议的描述符是 data descriptors ,如果只实现了 __get__ 协议的则是 non data descriptors 。好了我们现在来看个例子:importmath classlazyproperty: def__init__(self, func): self.func = func def__get__(self, instance, owner): ifinstanceisNone: returnself else: value = self.func(instance) setattr(instance, self.func.__name__, value) returnvalue classCircle: def__init__(self, radius): self.radius = radius pass @lazyproperty defarea(self): print("Com") returnmath.pi self.radius 2 deftest(self): pass if__name__=='__main__': c=Circle(4) print(c.area) 好的,让我们仔细来看看这段代码,首先类描述符 @lazyproperty 的替换过程,前面已经说了,我们不在重复。接着,在我们第一次调用 c.area 的时候,我们首先查询实例 c 的 __dict__ 中是否存在着 area 描述符,然后发现在 c 中既不存在描述符,也不存在这样一个属性,接着我们向上查询 Circle 中的 __dict__ ,然后查找到名为 area 的属性,同时这是一个 non data descriptors ,由于我们的实例字典内并不存在 area 属性,那么我们便调用类字典中的 area 的 __get__ 方法,并在 __get__ 方法中通过调用 setattr 方法为实例字典注册属性 area 。紧接着,我们在后续调用 c.area 的时候,我们能在实例字典中找到 area 属性的存在,且类字典中的 area 是一个 non data descriptors ,于是我们不会触发代码里所实现的 __get__ 方法,而是直接从实例的字典中直接获取属性值。 描述符的使用 描述符的使用面很广,不过其主要的目的在于让我们的调用过程变得可控。因此我们在一些需要对我们调用过程实行精细控制的时候,使用描述符,比如我们之前提到的这个例子classlazyproperty: def__init__(self, func): self.func = func def__get__(self, instance, owner): ifinstanceisNone: returnself else: value = self.func(instance) setattr(instance, self.func.__name__, value) returnvalue def__set__(self, instance, value=0): pass importmath classCircle: def__init__(self, radius): self.radius = radius pass @lazyproperty defarea(self, value=0): print("Com") ifvalue ==0andself.radius ==0: raiseTypeError("Something went wring") returnmath.pi value 2ifvalue !=0elsemath.pi self.radius 2 deftest(self): pass 利用描述符的特性实现懒加载,再比如,我们可以控制属性赋值的值classProperty(object): "Emulate PyProperty_Type() in Objects/descrobject.c" def__init__(self, fget=None, fset=None, fdel=None, doc=None): self.fget = fget self.fset = fset self.fdel = fdel ifdocisNoneandfgetisnotNone: doc = fget.__doc__ self.__doc__ = doc def__get__(self, obj, objtype=None): ifobjisNone: returnself ifself.fgetisNone: raiseAttributeError("unreadable attribute") returnself.fget(obj) def__set__(self, obj, value=None): ifvalueisNone: raiseTypeError("You cant to set value as None") ifself.fsetisNone: raiseAttributeError("can't set attribute") self.fset(obj, value) def__delete__(self, obj): ifself.fdelisNone: raiseAttributeError("can't delete attribute") self.fdel(obj) defgetter(self, fget): returntype(self)(fget, self.fset, self.fdel, self.__doc__) defsetter(self, fset): returntype(self)(self.fget, fset, self.fdel, self.__doc__) defdeleter(self, fdel): returntype(self)(self.fget, self.fset, fdel, self.__doc__) classtest(): def__init__(self, value): self.value = value @Property defValue(self): returnself.value @Value.setter deftest(self, x): self.value = x 如上面的例子所描述的一样,我们可以判断所传入的值是否有效等等。 以上就是Python 描述符(Descriptor)入门,更多相关文章请关注PHP中文网(www.gxlcms.com)! 本条技术文章来源于互联网,如果无意侵犯您的权益请点击此处反馈版权投诉 本文系统来源:php中文网 本篇文章为转载内容。原文链接:https://blog.csdn.net/weixin_39736934/article/details/112888600。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-05-07 19:03:49
94
转载
转载文章
...的代码无论如何都会被执行,常用于资源清理工作,如关闭数据库连接、文件流等。 using()结构 , 在C中,using语句提供了一种更简洁的方式来管理那些实现IDisposable接口的对象生命周期,以确保其Dispose方法在适当的时候被调用,从而释放非托管资源或执行其他清理任务。在本文中,通过将SqlConnection对象置于using语句中,可以自动在离开using代码块时关闭数据库连接,即使在执行过程中遇到异常也能确保资源得到释放。 SqlDataReader , SqlDataReader是.NET框架中System.Data.SqlClient命名空间下的一个类,它提供了一种只进、只读、高性能的方式从SQL Server数据库获取查询结果。在文中,SqlDataReader被用来执行SQL命令并逐行读取返回的数据集,进而将这些数据转换为CategoryInfo对象,并添加到IList集合中进行后续操作。它的特点是按需读取数据,而不是一次性加载所有数据到内存,因此适用于处理大量数据的情形。 CommandBehavior.CloseConnection , 这是SqlCommand.ExecuteReader方法的一个可选参数,当设置此标志时,在SqlDataReader关闭时,会同时关闭与之关联的SqlConnection。在文章中,作者建议通过设置CommandBehavior.CloseConnection,确保在完成数据读取后能自动关闭数据库连接,从而简化了代码并降低了资源泄漏的风险。
2023-03-18 20:09:36
89
转载
站内搜索
用于搜索本网站内部文章,支持栏目切换。
知识学习
实践的时候请根据实际情况谨慎操作。
随机学习一条linux命令:
alias ll='ls -l'
- 创建一个别名以快速查看详细文件列表。
推荐内容
推荐本栏目内的其它文章,看看还有哪些文章让你感兴趣。
2023-04-28
2023-08-09
2023-06-18
2023-04-14
2023-02-18
2023-04-17
2024-01-11
2023-10-03
2023-09-09
2023-06-13
2023-08-07
2023-03-11
历史内容
快速导航到对应月份的历史文章列表。
随便看看
拉到页底了吧,随便看看还有哪些文章你可能感兴趣。
时光飞逝
"流光容易把人抛,红了樱桃,绿了芭蕉。"